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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
//-----------------------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//-----------------------------------------------------------------------------
namespace System.ServiceModel.Dispatcher
{
using System;
using System.Runtime;
using System.ServiceModel;
using System.ServiceModel.Channels;
using System.ServiceModel.Diagnostics;
class ReplyChannelBinder : IChannelBinder
{
IReplyChannel channel;
Uri listenUri;
internal ReplyChannelBinder(IReplyChannel channel, Uri listenUri)
{
if (channel == null)
{
Fx.Assert("ReplyChannelBinder.ReplyChannelBinder: (channel != null)");
throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("channel");
}
this.channel = channel;
this.listenUri = listenUri;
}
public IChannel Channel
{
get { return this.channel; }
}
public bool HasSession
{
get { return this.channel is ISessionChannel<IInputSession>; }
}
public Uri ListenUri
{
get { return this.listenUri; }
}
public EndpointAddress LocalAddress
{
get { return this.channel.LocalAddress; }
}
public EndpointAddress RemoteAddress
{
get
{
#pragma warning suppress 56503 // [....], the property is really not implemented, cannot lie, API not public
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
}
public void Abort()
{
this.channel.Abort();
}
public void CloseAfterFault(TimeSpan timeout)
{
this.channel.Close(timeout);
}
public IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state)
{
return this.channel.BeginTryReceiveRequest(timeout, callback, state);
}
public bool EndTryReceive(IAsyncResult result, out RequestContext requestContext)
{
return this.channel.EndTryReceiveRequest(result, out requestContext);
}
public RequestContext CreateRequestContext(Message message)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
{
throw TraceUtility.ThrowHelperError(new NotImplementedException(), message);
}
public void EndSend(IAsyncResult result)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public void Send(Message message, TimeSpan timeout)
{
throw TraceUtility.ThrowHelperError(new NotImplementedException(), message);
}
public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
{
throw TraceUtility.ThrowHelperError(new NotImplementedException(), message);
}
public Message EndRequest(IAsyncResult result)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public bool TryReceive(TimeSpan timeout, out RequestContext requestContext)
{
return this.channel.TryReceiveRequest(timeout, out requestContext);
}
public Message Request(Message message, TimeSpan timeout)
{
throw TraceUtility.ThrowHelperError(new NotImplementedException(), message);
}
public bool WaitForMessage(TimeSpan timeout)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
public bool EndWaitForMessage(IAsyncResult result)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException());
}
}
}
|
