1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
//----------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//----------------------------------------------------------------
namespace System.ServiceModel.Routing
{
using System;
using System.Collections.Generic;
using System.ServiceModel.Channels;
using System.ServiceModel.Description;
using System.Transactions;
using System.Runtime;
using System.Configuration;
class SendOperation
{
List<RoutingEndpointTrait> endpointTraits;
int currentIndex;
bool sent;
Dictionary<string, Exception> exceptions;
OperationContext operationContext;
Type routerContract;
public SendOperation(IEnumerable<ServiceEndpoint> endpoints, Type routerContract, OperationContext operationContext)
{
this.operationContext = operationContext;
this.routerContract = routerContract;
this.endpointTraits = new List<RoutingEndpointTrait>();
foreach (ServiceEndpoint endpoint in endpoints)
{
this.endpointTraits.Add(new RoutingEndpointTrait(routerContract, endpoint, operationContext));
}
if (this.endpointTraits.Count == 0)
{
throw FxTrace.Exception.AsError(new ConfigurationErrorsException(SR.BackupListEmpty));
}
}
public RoutingEndpointTrait CurrentEndpoint
{
get
{
Fx.Assert(this.currentIndex < this.endpointTraits.Count, "CurrentEndpoint should not be accessed after TryMoveToAlternate returned false!");
RoutingEndpointTrait trait = this.endpointTraits[this.currentIndex];
return trait;
}
}
public bool HasAlternate
{
get { return this.currentIndex < (this.endpointTraits.Count - 1); }
}
public int AlternateEndpointCount
{
get { return (this.endpointTraits.Count - 1); }
}
public bool Sent
{
get { return this.sent; }
}
public void PrepareMessage(Message message)
{
if (this.exceptions != null)
{
message.Properties["Exceptions"] = this.exceptions;
}
}
public void TransmitSucceeded(Transaction sendTransaction)
{
if (sendTransaction == null)
{
this.sent = true;
}
}
public bool TryMoveToAlternate(Exception exception)
{
if (this.exceptions == null)
{
this.exceptions = new Dictionary<string, Exception>();
}
this.exceptions[this.CurrentEndpoint.Endpoint.Name] = exception;
this.sent = false;
if (++this.currentIndex < this.endpointTraits.Count)
{
return true;
}
return false;
}
}
}
|
