403 references to Message
Client.ChannelLayer.IntegrationTests (27)
DuplexChannelShapeTests.4.0.0.cs (6)
29Message replyMessage = null; 45Message requestMessage = Message.CreateMessage( 84Message replyMessage = null; 100Message requestMessage = Message.CreateMessage(
DuplexChannelShapeTests.4.1.0.cs (6)
26Message replyMessage = null; 42Message requestMessage = Message.CreateMessage( 86Message replyMessage = null; 102Message requestMessage = Message.CreateMessage(
RequestReplyChannelShapeTests.4.0.0.cs (12)
28Message replyMessage = null; 44Message requestMessage = Message.CreateMessage( 79Message replyMessage = null; 98Message requestMessage = Message.CreateMessage( 134Message replyMessage = null; 150Message requestMessage = Message.CreateMessage( 187Message replyMessage = null; 206Message requestMessage = Message.CreateMessage(
RequestReplyChannelShapeTests.4.1.0.cs (3)
27Message replyMessage = null; 43Message requestMessage = Message.CreateMessage(
Client.ClientBase.IntegrationTests (8)
ClientBaseTestHelpers.cs (6)
98public void AfterReceiveReply(ref Message reply, object correlationState) 102public object BeforeSendRequest(ref Message request, IClientChannel channel) 151public void AfterReceiveReply(ref Message reply, object correlationState) 157public object BeforeSendRequest(ref Message request, IClientChannel channel) 170public Message Request { get; set; } 171public Message Reply { get; set; }
MessageInspectorTestHelpers.cs (2)
109public void AfterReceiveReply(ref Message reply, object correlationState) 113public object BeforeSendRequest(ref Message request, IClientChannel channel)
Client.TypedClient.IntegrationTests (9)
TypedProxyTests.4.0.0.cs (9)
223Message replyMessage = null; 240Message requestMessage = Message.CreateMessage( 286Message requestMessage = null; 287Message replyMessage = null; 304requestMessage = Message.CreateMessage( 350Message requestMessage = null; 351Message replyMessage = null; 368requestMessage = Message.CreateMessage(
Contract.Message.IntegrationTests (11)
MessageContractCommon.4.1.0.cs (4)
141private Message _receivedMessage; 143public Message ReceivedMessage 151public void AfterReceiveReply(ref System.ServiceModel.Channels.Message reply, object correlationState) 159public object BeforeSendRequest(ref System.ServiceModel.Channels.Message request, IClientChannel channel)
MessageContractTests.cs (2)
112public void AfterReceiveReply(ref System.ServiceModel.Channels.Message reply, object correlationState) 121public object BeforeSendRequest(ref System.ServiceModel.Channels.Message request, IClientChannel channel)
MessageTests.4.0.0.cs (5)
33using (Message requestMessage = Message.CreateMessage( 39using (Message replyMessage = channel.Request(requestMessage)) 148public object DeserializeReply(Message message, object[] parameters) 155public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
Contract.XmlSerializer.IntegrationTests (2)
XmlSerializerFormatTest.cs (2)
41public void AfterReceiveReply(ref Message reply, object correlationState) 45public object BeforeSendRequest(ref Message request, IClientChannel channel)
dotnet-svcutil.xmlserializer.IntegrationTests (2)
src\System.Private.ServiceModel\tests\Scenarios\Contract\XmlSerializer\XmlSerializerFormatTest.cs (2)
41public void AfterReceiveReply(ref Message reply, object correlationState) 45public object BeforeSendRequest(ref Message request, IClientChannel channel)
Extensibility.MessageEncoder.IntegrationTests (5)
CustomTextMessageEncoder.cs (5)
54public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 57return Message.CreateMessage(reader, maxSizeOfHeaders, MessageVersion); 60public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 70public override void WriteMessage(Message message, Stream stream) 78public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
Extensibility.MessageInterceptor.IntegrationTests (42)
ChannelMessageInterceptor.cs (2)
10public virtual void OnSend(ref Message message) { } 11public virtual void OnReceive(ref Message message) { }
InterceptingChannelBase.cs (2)
85protected void OnReceive(ref Message message) 90protected void OnSend(ref Message message)
InterceptingChannelFactory.cs (17)
140public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 145public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 156public void Send(Message message) 161public void Send(Message message, TimeSpan timeout) 176public SendAsyncResult(IOutputChannel channel, Message message, TimeSpan timeout, AsyncCallback callback, object state) 255public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 260public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 266public Message EndRequest(IAsyncResult result) 268Message reply = RequestAsyncResult.End(result); 273public Message Request(Message message) 278public Message Request(Message message, TimeSpan timeout) 281Message reply = null; 293Message replyMessage; 297public RequestAsyncResult(InterceptingRequestChannel channel, Message message, TimeSpan timeout, AsyncCallback callback, object state) 343public static Message End(IAsyncResult result)
InterceptingDuplexChannel.cs (20)
29bool ProcessReceivedMessage(ref Message message) 31Message originalMessage = message; 36public Message Receive() 41public Message Receive(TimeSpan timeout) 43Message message; 68public Message EndReceive(IAsyncResult result) 73public bool TryReceive(TimeSpan timeout, out Message message) 95public bool EndTryReceive(IAsyncResult result, out Message message) 118Message message; 130protected Message Message 148protected abstract Message EndReceive(IAsyncResult result); 215protected override Message EndReceive(IAsyncResult result) 217Message message; 222public static bool End(IAsyncResult result, out Message message) 249protected override Message EndReceive(IAsyncResult result) 254public static Message End(IAsyncResult result) 288public void Send(Message message) 293public void Send(Message message, TimeSpan timeout) 299public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 304public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
MessageInterceptorTests.4.1.1.cs (1)
18public override void OnSend(ref Message msg)
Microsoft.Svcutil.NamedPipeMetadataImporter (7)
IMetadataExchange.cs (4)
15Message Get(Message request); 18IAsyncResult BeginGet(Message request, AsyncCallback callback, object state); 19Message EndGet(IAsyncResult result);
NamedPipeMetadataImporter.cs (3)
43var _message = Message.CreateMessage(messageVersion, WSTransfer.GetAction); 84Message response = metadataClient.EndGet(result);
ScenarioTests.Common.Tests (26)
ScenarioTestTypes.cs (6)
748public void ProvideFault(Exception error, MessageVersion version, ref Message msg) 755msg = Message.CreateMessage(version, fault, "http://tempuri.org/IWcfDuplexService_CallbackErrorHandler/ReplyThrowCustomMessageFault"); 884public IAsyncResult BeginMessageRequestReply(Message request, AsyncCallback callback, object asyncState) 898public Message EndMessageRequestReply(IAsyncResult result) 903public Message MessageRequestReply(Message request)
ServiceInterfaces.cs (20)
18Message MessageRequestReply(Message message); 185System.ServiceModel.Channels.Message MessageRequestReply(System.ServiceModel.Channels.Message request); 188System.Threading.Tasks.Task<System.ServiceModel.Channels.Message> MessageRequestReplyAsync(System.ServiceModel.Channels.Message request); 205System.ServiceModel.Channels.Message MessageRequestReply(System.ServiceModel.Channels.Message request); 208System.IAsyncResult BeginMessageRequestReply(System.ServiceModel.Channels.Message request, System.AsyncCallback callback, object asyncState); 210System.ServiceModel.Channels.Message EndMessageRequestReply(System.IAsyncResult result); 226Message MessageRequestReply(Message message); 238System.ServiceModel.Channels.Message MessageRequestReply(System.ServiceModel.Channels.Message request); 241System.Threading.Tasks.Task<System.ServiceModel.Channels.Message> MessageRequestReplyAsync(System.ServiceModel.Channels.Message request); 256System.ServiceModel.Channels.Message MessageRequestReply(System.ServiceModel.Channels.Message request); 259System.IAsyncResult BeginMessageRequestReply(System.ServiceModel.Channels.Message request, System.AsyncCallback callback, object asyncState); 261System.ServiceModel.Channels.Message EndMessageRequestReply(System.IAsyncResult result);
System.ServiceModel (1)
netstandard.cs (1)
74[assembly: TypeForwardedTo(typeof(Message))]
System.ServiceModel.Federation (15)
System\ServiceModel\Federation\WSTrustChannel.cs (9)
46/// The <see cref="IRequestChannel" /> this class uses for sending and receiving <see cref="Message" /> objects. 51/// Gets the version of WS-Trust this channel will use for serializing <see cref="Message" /> objects. 56/// Gets the version of WS-Trust this channel will use for serializing <see cref="Message" /> objects. 69/// Creates a <see cref="Message"/> that represents a the <see cref="WsTrustRequest"/>. 72/// <returns>The <see cref="Message" /> that represents the <see cref="WsTrustRequest"/>.</returns> 73protected virtual Message CreateRequest(WsTrustRequest trustRequest) 76return Message.CreateMessage(MessageVersion, 360Message requestMessage = CreateRequest(trustRequest); 361Message response = await Task.Factory.FromAsync(RequestChannel.BeginRequest, RequestChannel.EndRequest, requestMessage, null, TaskCreationOptions.None).ConfigureAwait(false);
System\ServiceModel\Federation\WSTrustChannelSecurityTokenProvider.cs (5)
246Message requestMessage = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, _requestSerializationContext.TrustActions.IssueRequest, reader); 247Message reply = await Task.Factory.FromAsync(channel.BeginRequest, channel.EndRequest, requestMessage, null, TaskCreationOptions.None); 285Message reply = channel.Request(Message.CreateMessage(MessageVersion.Soap12WSAddressing10, _requestSerializationContext.TrustActions.IssueRequest, reader));
System\ServiceModel\Security\SecurityUtils.cs (1)
13internal static void ThrowIfNegotiationFault(Message message, EndpointAddress target)
System.ServiceModel.NetFramingBase (60)
System\ServiceModel\Channels\ChannelBindingUtility.cs (1)
31public static void TryAddToMessage(ChannelBinding channelBindingToken, Message message, bool messagePropertyOwnsCleanup)
System\ServiceModel\Channels\FramingChannels.cs (5)
52protected override async ValueTask OnSendCoreAsync(Message message, TimeSpan timeout) 70protected override ValueTask StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout) 75protected override ValueTask StartWritingStreamedMessage(Message message, TimeSpan timeout) 81protected override ArraySegment<byte> EncodeMessage(Message message) 340protected override void PrepareMessage(Message message)
System\ServiceModel\Channels\IMessageSource.cs (1)
12Task<Message> ReceiveAsync(TimeSpan timeout);
System\ServiceModel\Channels\OutputChannel.cs (10)
21public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 26public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 66protected abstract void OnSend(Message message, TimeSpan timeout); 68protected abstract Task OnSendAsync(Message message, TimeSpan timeout); 70public void Send(Message message) 75public void Send(Message message, TimeSpan timeout) 95public Task SendAsync(Message message) 100public Task SendAsync(Message message, TimeSpan timeout) 120private void EmitTrace(Message message) 124protected virtual void AddHeadersTo(Message message)
System\ServiceModel\Channels\SessionConnectionReader.cs (11)
24private Message _pendingMessage; 34private Message DecodeMessage(TimeSpan timeout) 50protected abstract Message DecodeMessage(byte[] buffer, ref int offset, ref int size, ref bool isAtEof, TimeSpan timeout); 62public async Task<Message> ReceiveAsync(TimeSpan timeout) 64Message message = GetPendingMessage(); 128private Message GetPendingMessage() 139Message message = _pendingMessage; 151Message message = await ReceiveAsync(timeout); 184protected virtual void PrepareMessage(Message message) 225protected override Message DecodeMessage(byte[] buffer, ref int offset, ref int size, ref bool isAtEOF, TimeSpan timeout) 271Message message = null;
System\ServiceModel\Channels\SingletonConnectionReader.cs (4)
129protected virtual void PrepareMessage(Message message) 135public async Task<Message> ReceiveAsync(TimeoutHelper timeoutHelper) 185Message message = null; 560public async static Task WriteMessageAsync(Message message, IConnection connection, bool isRequest,
System\ServiceModel\Channels\StreamedFramingRequestChannel.cs (5)
68protected override IAsyncRequest CreateAsyncRequest(Message message) => new StreamedConnectionPoolHelper.StreamedFramingAsyncRequest(this); 203private Message _message; 213public async Task SendRequestAsync(Message message, TimeoutHelper timeoutHelper) 256public async Task<Message> ReceiveReplyAsync(TimeoutHelper timeoutHelper) 262Message message = await _connectionReader.ReceiveAsync(timeoutHelper);
System\ServiceModel\Channels\SynchronizedMessageSource.cs (1)
45public async Task<Message> ReceiveAsync(TimeSpan timeout)
System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (22)
60public Message Receive() 65public Message Receive(TimeSpan timeout) 70public Task<Message> ReceiveAsync() 75public async Task<Message> ReceiveAsync(TimeSpan timeout) 77Message message = null; 116public Message EndReceive(IAsyncResult result) 118return result.ToApmEnd<Message>(); 126public bool EndTryReceive(IAsyncResult result, out Message message) 130message = result.ToApmEnd<Message>(); 145public async Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout) 163public bool TryReceive(TimeSpan timeout, out Message message) 339protected virtual void OnReceiveMessage(Message message) 351protected void ApplyChannelBinding(Message message) 356protected virtual void PrepareMessage(Message message) 382protected abstract ValueTask StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout); 386protected abstract ArraySegment<byte> EncodeMessage(Message message); 388protected abstract ValueTask OnSendCoreAsync(Message message, TimeSpan timeout); 390protected abstract ValueTask StartWritingStreamedMessage(Message message, TimeSpan timeout); 392protected override async Task OnSendAsync(Message message, TimeSpan timeout) 468protected override void OnSend(Message message, TimeSpan timeout) 532Message message = await MessageSource.ReceiveAsync(timeout); 655internal static ProtocolException ReceiveShutdownReturnedNonNull(Message message)
System.ServiceModel.Primitives (70)
netstandard.cs (70)
536System.IAsyncResult System.ServiceModel.Channels.IOutputChannel.BeginSend(System.ServiceModel.Channels.Message message, System.AsyncCallback callback, object state) { return default; } 537System.IAsyncResult System.ServiceModel.Channels.IOutputChannel.BeginSend(System.ServiceModel.Channels.Message message, System.TimeSpan timeout, System.AsyncCallback callback, object state) { return default; } 539void System.ServiceModel.Channels.IOutputChannel.Send(System.ServiceModel.Channels.Message message) { } 540void System.ServiceModel.Channels.IOutputChannel.Send(System.ServiceModel.Channels.Message message, System.TimeSpan timeout) { } 541System.IAsyncResult System.ServiceModel.Channels.IRequestChannel.BeginRequest(System.ServiceModel.Channels.Message message, System.AsyncCallback callback, object state) { return default; } 542System.IAsyncResult System.ServiceModel.Channels.IRequestChannel.BeginRequest(System.ServiceModel.Channels.Message message, System.TimeSpan timeout, System.AsyncCallback callback, object state) { return default; } 543System.ServiceModel.Channels.Message System.ServiceModel.Channels.IRequestChannel.EndRequest(System.IAsyncResult result) { return default; } 544System.ServiceModel.Channels.Message System.ServiceModel.Channels.IRequestChannel.Request(System.ServiceModel.Channels.Message message) { return default; } 545System.ServiceModel.Channels.Message System.ServiceModel.Channels.IRequestChannel.Request(System.ServiceModel.Channels.Message message, System.TimeSpan timeout) { return default; } 636public void ApplyTo(System.ServiceModel.Channels.Message message) { } 1065public System.ServiceModel.Channels.Message Message { get { return default; } } 1082public object GetServiceInstance(System.ServiceModel.Channels.Message message) { return default(object); } 1203public void AddHeadersTo(System.ServiceModel.Channels.Message message) { } 1435protected abstract bool OnTryCreateException(System.ServiceModel.Channels.Message message, System.ServiceModel.Channels.MessageFault fault, out System.Exception exception); 1436protected abstract bool OnTryCreateFaultMessage(System.Exception exception, out System.ServiceModel.Channels.Message message); 1437public bool TryCreateException(System.ServiceModel.Channels.Message message, System.ServiceModel.Channels.MessageFault fault, out System.Exception exception) { exception = default; return default; } 1478System.ServiceModel.Channels.Message EndReceive(System.IAsyncResult result); 1479bool EndTryReceive(System.IAsyncResult result, out System.ServiceModel.Channels.Message message); 1481System.ServiceModel.Channels.Message Receive(); 1482System.ServiceModel.Channels.Message Receive(System.TimeSpan timeout); 1483bool TryReceive(System.TimeSpan timeout, out System.ServiceModel.Channels.Message message); 1500System.IAsyncResult BeginSend(System.ServiceModel.Channels.Message message, System.AsyncCallback callback, object state); 1501System.IAsyncResult BeginSend(System.ServiceModel.Channels.Message message, System.TimeSpan timeout, System.AsyncCallback callback, object state); 1503void Send(System.ServiceModel.Channels.Message message); 1504void Send(System.ServiceModel.Channels.Message message, System.TimeSpan timeout); 1516System.IAsyncResult BeginRequest(System.ServiceModel.Channels.Message message, System.AsyncCallback callback, object state); 1517System.IAsyncResult BeginRequest(System.ServiceModel.Channels.Message message, System.TimeSpan timeout, System.AsyncCallback callback, object state); 1518System.ServiceModel.Channels.Message EndRequest(System.IAsyncResult result); 1519System.ServiceModel.Channels.Message Request(System.ServiceModel.Channels.Message message); 1520System.ServiceModel.Channels.Message Request(System.ServiceModel.Channels.Message message, System.TimeSpan timeout); 1545public static System.ServiceModel.Channels.Message CreateMessage(System.ServiceModel.Channels.MessageVersion version, string action) { return default; } 1546public static System.ServiceModel.Channels.Message CreateMessage(System.ServiceModel.Channels.MessageVersion version, string action, object body) { return default; } 1547public static System.ServiceModel.Channels.Message CreateMessage(System.ServiceModel.Channels.MessageVersion version, string action, object body, System.Runtime.Serialization.XmlObjectSerializer serializer) { return default; } 1548public static System.ServiceModel.Channels.Message CreateMessage(System.ServiceModel.Channels.MessageVersion version, string action, System.ServiceModel.Channels.BodyWriter body) { return default; } 1549public static System.ServiceModel.Channels.Message CreateMessage(System.ServiceModel.Channels.MessageVersion version, string action, System.Xml.XmlDictionaryReader body) { return default; } 1550public static System.ServiceModel.Channels.Message CreateMessage(System.ServiceModel.Channels.MessageVersion version, string action, System.Xml.XmlReader body) { return default; } 1551public static System.ServiceModel.Channels.Message CreateMessage(System.Xml.XmlDictionaryReader envelopeReader, int maxSizeOfHeaders, System.ServiceModel.Channels.MessageVersion version) { return default; } 1552public static System.ServiceModel.Channels.Message CreateMessage(System.Xml.XmlReader envelopeReader, int maxSizeOfHeaders, System.ServiceModel.Channels.MessageVersion version) { return default; } 1553public static System.ServiceModel.Channels.Message CreateMessage(System.ServiceModel.Channels.MessageVersion version, System.ServiceModel.FaultCode faultCode, string reason, string action) { return default; } 1554public static System.ServiceModel.Channels.Message CreateMessage(System.ServiceModel.Channels.MessageVersion version, System.ServiceModel.FaultCode faultCode, string reason, object detail, string action) { return default; } 1587public abstract System.ServiceModel.Channels.Message CreateMessage(); 1599public System.ServiceModel.Channels.Message ReadMessage(System.ArraySegment<byte> buffer, System.ServiceModel.Channels.BufferManager bufferManager) { return default; } 1600public abstract System.ServiceModel.Channels.Message ReadMessage(System.ArraySegment<byte> buffer, System.ServiceModel.Channels.BufferManager bufferManager, string contentType); 1601public System.ServiceModel.Channels.Message ReadMessage(System.IO.Stream stream, int maxSizeOfHeaders) { return default; } 1602public abstract System.ServiceModel.Channels.Message ReadMessage(System.IO.Stream stream, int maxSizeOfHeaders, string contentType); 1604public System.ArraySegment<byte> WriteMessage(System.ServiceModel.Channels.Message message, int maxMessageSize, System.ServiceModel.Channels.BufferManager bufferManager) { return default; } 1605public abstract System.ArraySegment<byte> WriteMessage(System.ServiceModel.Channels.Message message, int maxMessageSize, System.ServiceModel.Channels.BufferManager bufferManager, int messageOffset); 1606public abstract void WriteMessage(System.ServiceModel.Channels.Message message, System.IO.Stream stream); 1631public static System.ServiceModel.Channels.MessageFault CreateFault(System.ServiceModel.Channels.Message message, int maxBufferSize) { return default; } 1693public void CopyHeaderFrom(System.ServiceModel.Channels.Message message, int headerIndex) { } 1695public void CopyHeadersFrom(System.ServiceModel.Channels.Message message) { } 1815public abstract System.ServiceModel.Channels.Message RequestMessage { get; } 1817public abstract System.IAsyncResult BeginReply(System.ServiceModel.Channels.Message message, System.AsyncCallback callback, object state); 1818public abstract System.IAsyncResult BeginReply(System.ServiceModel.Channels.Message message, System.TimeSpan timeout, System.AsyncCallback callback, object state); 1823public abstract void Reply(System.ServiceModel.Channels.Message message); 1824public abstract void Reply(System.ServiceModel.Channels.Message message, System.TimeSpan timeout); 2133public abstract System.ServiceModel.Channels.Message ToMessage(object typedMessage); 2134public abstract System.ServiceModel.Channels.Message ToMessage(object typedMessage, System.ServiceModel.Channels.MessageVersion version); 2135public abstract object FromMessage(System.ServiceModel.Channels.Message message); 2215object DeserializeReply(System.ServiceModel.Channels.Message message, object[] parameters); 2216System.ServiceModel.Channels.Message SerializeRequest(System.ServiceModel.Channels.MessageVersion messageVersion, object[] parameters); 2220void AfterReceiveReply(ref System.ServiceModel.Channels.Message reply, object correlationState); 2221object BeforeSendRequest(ref System.ServiceModel.Channels.Message request, System.ServiceModel.IClientChannel channel); 2225object AfterReceiveRequest(ref System.ServiceModel.Channels.Message request, IClientChannel channel, System.ServiceModel.InstanceContext instanceContext); 2226void BeforeSendReply(ref System.ServiceModel.Channels.Message reply, object correlationState); 2372public static SecurityMessageProperty GetOrCreate(System.ServiceModel.Channels.Message message) => default;
System.ServiceModel.Primitives.Tests (80)
Channels\BehaviorExtensionTest.cs (14)
23Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 36Message outputMessage = channel.Process(inputMessage); 55Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 69Message outputMessage = channel.Process(inputMessage); 94Message Process(Message input); 102Message Process(Message input); 107public Message Process(Message input) { return input; } 113public Message Process(Message input) { return input; }
Channels\CustomChannelTest.cs (34)
29Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 64Message outputMessage = channel.Process(inputMessage); 119Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 158Task<Message> processTask = channel.ProcessAsync(inputMessage); 161Message outputMessage = processTask.GetAwaiter().GetResult(); 212Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 227mockRequestChannel.RequestOverride = (Message m, TimeSpan t) => 263Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 297Task<Message> processTask = channel.ProcessAsync(inputMessage); 321Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 356Message outputMessage = channel.Process(inputMessage); 402Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 440Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 480Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 531Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 582Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 634Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 687Message inputMessage = Message.CreateMessage(MessageVersion.Default, action: "Test", body: testMessageBody); 736Message Process(Message input); 739Task<Message> ProcessAsync(Message input);
Channels\MessageTest.cs (9)
27var message = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, s_action); 38var message = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, s_action, body); 53var message = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, s_action, new CustomBodyWriter()); 89var message = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, faultCode, faultReason, s_action); 99message = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, faultCode, faultReason, faultDetail, s_action);
Channels\UnderstoodHeadersTest.cs (2)
19Message requestMessage = Message.CreateMessage(
ServiceModel\MessageContractTest.4.4.0.cs (1)
262Message replyMsg = buffer.CreateMessage();
ServiceModel\ThrowingOnCloseBindingElement.cs (20)
194public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) => InnerChannel.BeginSend(message, callback, state); 195public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) => InnerChannel.BeginSend(message, timeout, callback, state); 197public void Send(Message message) => InnerChannel.Send(message); 198public void Send(Message message, TimeSpan timeout) => InnerChannel.Send(message, timeout); 211public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) => InnerChannel.BeginRequest(message, callback, state); 212public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) => InnerChannel.BeginRequest(message, timeout, callback, state); 213public Message EndRequest(IAsyncResult result) => InnerChannel.EndRequest(result); 214public Message Request(Message message) => InnerChannel.Request(message); 215public Message Request(Message message, TimeSpan timeout) => InnerChannel.Request(message, timeout); 253public Message Receive() => InnerChannel.Receive(); 254public Message Receive(TimeSpan timeout) => InnerChannel.Receive(timeout); 257public Message EndReceive(IAsyncResult result) => InnerChannel.EndReceive(result); 258public bool TryReceive(TimeSpan timeout, out Message message) => InnerChannel.TryReceive(timeout, out message); 260public bool EndTryReceive(IAsyncResult result, out Message message) => InnerChannel.EndTryReceive(result, out message); 275public void Send(Message message) => InnerChannel.Send(message); 276public void Send(Message message, TimeSpan timeout) => InnerChannel.Send(message, timeout); 277public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) => InnerChannel.BeginSend(message, callback, state); 278public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) => InnerChannel.BeginSend(message, callback, state);
UnitTests.Common (38)
MockClientMessageInspector.cs (6)
11public delegate void AfterReceiveReplyDelegate(ref Message reply, object correlationState); 12public delegate object BeforeSendRequestDelegate(ref Message request, IClientChannel channel); 69public void AfterReceiveReply(ref Message reply, object correlationState) 74public void DefaultAfterReceiveReply(ref Message reply, object correlationState) 78public object BeforeSendRequest(ref Message request, IClientChannel channel) 83public object DefaultBeforeSendRequest(ref Message request, IClientChannel channel)
MockRequestChannel.cs (16)
18public Func<Message, TimeSpan, Message> RequestOverride { get; set; } 19public Func<Message,TimeSpan,AsyncCallback,object, IAsyncResult> BeginRequestOverride { get; set; } 20public Func<IAsyncResult, Message> EndRequestOverride { get; set; } 32public Message Request(Message message, TimeSpan timeout) 37public Message DefaultRequest(Message message, TimeSpan timeout) 44public Message Request(Message message) 49public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 54public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 59public IAsyncResult DefaultBeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 68public Message EndRequest(IAsyncResult result) 73public Message DefaultEndRequest(IAsyncResult result) 76return (Message)((MockAsyncResult)result).Result;
ServiceInterfaces.cs (16)
18Message MessageRequestReply(Message message); 75System.ServiceModel.Channels.Message MessageRequestReply(System.ServiceModel.Channels.Message request); 78System.Threading.Tasks.Task<System.ServiceModel.Channels.Message> MessageRequestReplyAsync(System.ServiceModel.Channels.Message request); 96Message MessageRequestReply(Message message); 108System.ServiceModel.Channels.Message MessageRequestReply(System.ServiceModel.Channels.Message request); 111System.Threading.Tasks.Task<System.ServiceModel.Channels.Message> MessageRequestReplyAsync(System.ServiceModel.Channels.Message request); 126System.ServiceModel.Channels.Message MessageRequestReply(System.ServiceModel.Channels.Message request); 129System.IAsyncResult BeginMessageRequestReply(System.ServiceModel.Channels.Message request, System.AsyncCallback callback, object asyncState); 131System.ServiceModel.Channels.Message EndMessageRequestReply(System.IAsyncResult result);