4 types derived from Message
System.ServiceModel.Primitives (4)
System\ServiceModel\Channels\ContentOnlyMessage.cs (1)
14internal abstract class ContentOnlyMessage : Message
System\ServiceModel\Channels\DelegatingMessage.cs (1)
9internal abstract class DelegatingMessage : Message
System\ServiceModel\Channels\Message.cs (2)
1027internal class BodyWriterMessage : Message 1236internal abstract class ReceivedMessage : Message
1305 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 (24)
ScenarioTestTypes.cs (4)
831public IAsyncResult BeginMessageRequestReply(Message request, AsyncCallback callback, object asyncState) 845public Message EndMessageRequestReply(IAsyncResult result) 850public 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.Federation (14)
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)
260Message requestMessage = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, _requestSerializationContext.TrustActions.IssueRequest, reader); 261Message reply = await Task.Factory.FromAsync(channel.BeginRequest, channel.EndRequest, requestMessage, null, TaskCreationOptions.None); 299Message reply = channel.Request(Message.CreateMessage(MessageVersion.Soap12WSAddressing10, _requestSerializationContext.TrustActions.IssueRequest, reader));
System.ServiceModel.Http (62)
System\ServiceModel\Channels\HttpChannelFactory.cs (7)
700private void ApplyManualAddressing(ref EndpointAddress to, ref Uri via, Message message) 908protected override IAsyncRequest CreateAsyncRequest(Message message) 993public async Task SendRequestAsync(Message message, TimeoutHelper timeoutHelper) 1008Message request = message; 1129public async Task<Message> ReceiveReplyAsync(TimeoutHelper timeoutHelper) 1135var replyMessage = await responseHelper.ParseIncomingResponse(timeoutHelper); 1155private bool PrepareMessageHeaders(Message message)
System\ServiceModel\Channels\HttpResponseMessageHelper.cs (9)
38internal async Task<Message> ParseIncomingResponse(TimeoutHelper timeoutHelper) 43Message message = null; 67private Exception ProcessHttpAddressing(Message message) 122private void AddProperties(Message message) 169private Task<Message> ReadStreamAsMessageAsync(TimeoutHelper timeoutHelper) 187private async Task<Message> ReadChunkedBufferedMessageAsync(Task<Stream> inputStreamTask, TimeoutHelper timeoutHelper) 200private async Task<Message> ReadBufferedMessageAsync(Task<Stream> inputStreamTask, TimeoutHelper timeoutHelper) 237private async Task<Message> ReadStreamedMessageAsync(Task<Stream> inputStreamTask) 272private async Task<Message> DecodeBufferedMessageAsync(ArraySegment<byte> buffer, Stream inputStream, TimeoutHelper timeoutHelper)
System\ServiceModel\Channels\HttpTransportSecurityHelpers.cs (1)
20public static void AddIdentityMapping(EndpointAddress target, Message message)
System\ServiceModel\Channels\IMessageSource.cs (1)
12Task<Message> ReceiveAsync(TimeSpan timeout);
System\ServiceModel\Channels\MessageContent.cs (6)
19protected Message _message; 26public MessageContent(Message message, MessageEncoder messageEncoder, BufferManager bufferManager) 37public Message Message { get { return _message; } } 160internal static HttpContent Create(HttpChannelFactory<IRequestChannel> factory, Message request, TimeoutHelper _timeoutHelper) 175public StreamedMessageContent(Message message, MessageEncoder messageEncoder, BufferManager bufferManager) : base(message, messageEncoder, bufferManager) 229public BufferedMessageContent(Message message, MessageEncoder messageEncoder, BufferManager bufferManager) : base(message, messageEncoder, bufferManager)
System\ServiceModel\Channels\SynchronizedMessageSource.cs (1)
47public async Task<Message> ReceiveAsync(TimeSpan timeout)
System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (21)
57public Message Receive() 62public Message Receive(TimeSpan timeout) 67public Task<Message> ReceiveAsync() 72public async Task<Message> ReceiveAsync(TimeSpan timeout) 74Message message = null; 113public Message EndReceive(IAsyncResult result) 115return result.ToApmEnd<Message>(); 123public bool EndTryReceive(IAsyncResult result, out Message message) 127message = result.ToApmEnd<Message>(); 143public async Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout) 161public bool TryReceive(TimeSpan timeout, out Message message) 388protected virtual void OnReceiveMessage(Message message) 400protected void ApplyChannelBinding(Message message) 405protected virtual void PrepareMessage(Message message) 431protected abstract AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state); 439protected abstract ArraySegment<byte> EncodeMessage(Message message); 441protected abstract void OnSendCore(Message message, TimeSpan timeout); 443protected abstract AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, Action<object> callback, object state); 445protected override async Task OnSendAsync(Message message, TimeSpan timeout) 550protected override void OnSend(Message message, TimeSpan timeout) 614Message message = await MessageSource.ReceiveAsync(timeout);
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (16)
165protected override AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state) 205protected override AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, Action<object> callback, object state) 245protected override void OnSendCore(Message message, TimeSpan timeout) 302protected override ArraySegment<byte> EncodeMessage(Message message) 375private static WebSocketMessageType GetWebSocketMessageType(Message message) 447private Message _pendingMessage; 500public async Task<Message> ReceiveAsync(TimeSpan timeout) 512Message message = GetPendingMessage(); 522public Message Receive(TimeSpan timeout) 527private async Task<Message> ReceiveAsyncInternal(TimeSpan timeout) 631Message message = Receive(timeout); 651Message message = await ReceiveAsync(timeout); 785private Message GetPendingMessage() 791Message pendingMessage = _pendingMessage; 799private Message PrepareMessage(WebSocketReceiveResult result, byte[] buffer, int count) 803Message message;
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 (914)
SMDiagnostics\System\ServiceModel\Diagnostics\ExceptionUtility.cs (1)
100internal Exception ThrowHelperError(Exception exception, Message message)
System\ServiceModel\ActionMismatchAddressingException.cs (3)
29internal Message ProvideFault(MessageVersion messageVersion) 33Message message = Channels.Message.CreateMessage(messageVersion, phf, messageVersion.Addressing.FaultAction);
System\ServiceModel\ActionNotSupportedException.cs (2)
21internal Message ProvideFault(MessageVersion messageVersion) 26return Channels.Message.CreateMessage(messageVersion, code, reason, messageVersion.Addressing.FaultAction);
System\ServiceModel\Channels\AddressHeaderCollection.cs (1)
62public void AddHeadersTo(Message message)
System\ServiceModel\Channels\BinaryMessageEncoder.cs (11)
506public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 543Message message; 572public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 593Message message = Message.CreateMessage(reader, maxSizeOfHeaders, _factory._messageVersion); 609public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 723public override void WriteMessage(Message message, Stream stream) 807public void AddCompressedMessageProperties(Message message, string supportedCompressionTypes) 857private CompressionFormat CheckCompressedWrite(Message message) 1302public Message TryCreateMessage(byte[] buffer, int offset, int size, BufferManager bufferManager, BufferedMessageData messageData) 1773public override Message CreateMessage()
System\ServiceModel\Channels\BufferedMessageWriter.cs (1)
28public ArraySegment<byte> WriteMessage(Message message, BufferManager bufferManager, int initialOffset, int maxSizeQuota)
System\ServiceModel\Channels\ChannelBindingMessageProperty.cs (2)
46public static bool TryGet(Message message, out ChannelBindingMessageProperty property) 75public void AddTo(Message message)
System\ServiceModel\Channels\ChannelReliableSession.cs (7)
22private Message _terminatingFault; 156Message faultMessage = (fault == null) ? null : fault.CreateMessage(Settings.MessageVersion, 161public void OnLocalFault(Exception e, Message faultMessage, RequestContext context) 287OnLocalFault(e, (Message)null, null); 330OnLocalFault(throwException ? null : e, (Message)null, context); 608Message response = await _requestor.RequestAsync(timeout); 725private void ProcessCreateSequenceResponse(Message response, DateTime start)
System\ServiceModel\Channels\ClientReliableChannelBinder.cs (17)
130protected virtual Task<Message> OnRequestAsync(TChannel channel, Message message, TimeSpan timeout, 136public Task<Message> RequestAsync(Message message, TimeSpan timeout) 141public async Task<Message> RequestAsync(Message message, TimeSpan timeout, MaskingMode maskingMode) 272protected override Task OnSendAsync(TDuplexChannel channel, Message message, 288Message message; 295(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(channel.BeginTryReceive, channel.EndTryReceive, timeout, null); 384private InputQueue<Message> _inputMessages; 394protected void EnqueueMessageIfNotNull(Message message) 402private InputQueue<Message> GetInputMessages() 418_inputMessages = TraceUtility.CreateInputQueue<Message>(); 449protected override Task<Message> OnRequestAsync(TRequestChannel channel, Message message, 462protected override async Task OnSendAsync(TRequestChannel channel, Message message, 479(bool success, Message message) = await GetInputMessages().TryDequeueAsync(timeout);
System\ServiceModel\Channels\ClientReliableDuplexSessionChannel.cs (16)
19private DeliveryStrategy<Message> _deliveryStrategy; 58private void AddPendingAcknowledgements(Message message) 96private Message CreateAcknowledgmentMessage() 103Message message = WsrmUtilities.CreateAcknowledgmentMessage(Settings.MessageVersion, 267Message message = null; 664using (Message message = CreateAcknowledgmentMessage()) 707ReliableSession.OnLocalFault(exception, (Message)null, null); 824protected override async Task OnSendAsync(Message message, TimeSpan timeout) 879using (Message message = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion, 904_deliveryStrategy = new OrderedDeliveryStrategy<Message>(this, Settings.MaxTransferWindowSize, false); 906_deliveryStrategy = new UnorderedDeliveryStrategy<Message>(this, Settings.MaxTransferWindowSize); 950ReliableSession.OnLocalFault(e, (Message)null, null); 956Message message = context.RequestMessage; 992Message message = WsrmUtilities.CreateTerminateMessage(Settings.MessageVersion, 1205using (Message message = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion, 1229Message message = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion,
System\ServiceModel\Channels\CreateSequence.cs (5)
78Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 99Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 139Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 154Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 163Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
System\ServiceModel\Channels\DelegatingMessage.cs (2)
11protected DelegatingMessage(Message innerMessage) 44protected Message InnerMessage { get; }
System\ServiceModel\Channels\DuplexChannel.cs (19)
10internal abstract class DuplexChannel : InputQueueChannel<Message>, IDuplexChannel, IAsyncDuplexChannel 21public Task SendAsync(Message message) 26public Task SendAsync(Message message, TimeSpan timeout) 41public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 46public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 72protected abstract Task OnSendAsync(Message message, TimeSpan timeout); 74public void Send(Message message) 79public void Send(Message message, TimeSpan timeout) 84protected virtual void AddHeadersTo(Message message) 88public Task<Message> ReceiveAsync() 93public Task<Message> ReceiveAsync(TimeSpan timeout) 103public Message Receive() 108public Message Receive(TimeSpan timeout) 123public Message EndReceive(IAsyncResult result) 125return result.ToApmEnd<Message>(); 128public Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout) 138public bool TryReceive(TimeSpan timeout, out Message message) 150public bool EndTryReceive(IAsyncResult result, out Message message) 153(success, message) = result.ToApmEnd<(bool, Message)>();
System\ServiceModel\Channels\FaultConverter.cs (6)
17protected abstract bool OnTryCreateException(Message message, MessageFault fault, out Exception exception); 18protected abstract bool OnTryCreateFaultMessage(Exception exception, out Message message); 20public bool TryCreateException(Message message, MessageFault fault, out Exception exception) 55public bool TryCreateFaultMessage(Exception exception, out Message message) 90protected override bool OnTryCreateException(Message message, MessageFault fault, out Exception exception) 198protected override bool OnTryCreateFaultMessage(Exception exception, out Message message)
System\ServiceModel\Channels\ICompressedMessageEncoder.cs (1)
14void AddCompressedMessageProperties(Message message, string supportedCompressionTypes);
System\ServiceModel\Channels\IInputChannel.cs (8)
14Message Receive(); 15Message Receive(TimeSpan timeout); 18Message EndReceive(IAsyncResult result); 20bool TryReceive(TimeSpan timeout, out Message message); 22bool EndTryReceive(IAsyncResult result, out Message message); 31Task<Message> ReceiveAsync(); 32Task<Message> ReceiveAsync(TimeSpan timeout); 33Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout);
System\ServiceModel\Channels\InputChannel.cs (2)
11internal static async Task<Message> HelpReceiveAsync(IAsyncInputChannel channel, TimeSpan timeout) 13(bool success, Message message) = await channel.TryReceiveAsync(timeout);
System\ServiceModel\Channels\IOutputChannel.cs (6)
14void Send(Message message); 15void Send(Message message, TimeSpan timeout); 16IAsyncResult BeginSend(Message message, AsyncCallback callback, object state); 17IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state); 23Task SendAsync(Message message); 24Task SendAsync(Message message, TimeSpan timeout);
System\ServiceModel\Channels\IReliableChannelBinder.cs (6)
29Task SendAsync(Message message, TimeSpan timeout); 30Task SendAsync(Message message, TimeSpan timeout, MaskingMode maskingMode); 49Task<Message> RequestAsync(Message message, TimeSpan timeout); 50Task<Message> RequestAsync(Message message, TimeSpan timeout, MaskingMode maskingMode);
System\ServiceModel\Channels\IRequestChannel.cs (11)
15Message Request(Message message); 16Message Request(Message message, TimeSpan timeout); 17IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state); 18IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state); 19Message EndRequest(IAsyncResult result); 26Task<Message> RequestAsync(Message message); 27Task<Message> RequestAsync(Message message, TimeSpan timeout);
System\ServiceModel\Channels\IRequestReplyCorrelator.cs (2)
14void Add<T>(Message request, T state); 17T Find<T>(Message reply, bool remove);
System\ServiceModel\Channels\IStreamedMessageEncoder.cs (1)
12Stream GetResponseMessageStream(Message message);
System\ServiceModel\Channels\LayeredChannelFactory.cs (22)
100private Task InternalOnReceiveAsync(Message message) 110protected virtual Task OnReceiveAsync(Message message) 115public Message Receive() 120public async Task<Message> ReceiveAsync(TimeSpan timeout) 122Message message; 136public async Task<Message> ReceiveAsync() 138Message message; 152public Message Receive(TimeSpan timeout) 167public Message EndReceive(IAsyncResult result) 169return result.ToApmEnd<Message>(); 177public bool EndTryReceive(IAsyncResult result, out Message message) 180(retVal, message) = result.ToApmEnd<(bool, Message)>(); 184public async Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout) 187Message message; 194(retVal, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(InnerChannel.BeginTryReceive, InnerChannel.EndTryReceive, timeout, null); 201public bool TryReceive(TimeSpan timeout, out Message message) 309public Task SendAsync(Message message) 314public Task SendAsync(Message message, TimeSpan timeout) 326public void Send(Message message) 331public void Send(Message message, TimeSpan timeout) 336public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 341public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\Message.cs (21)
116static public Message CreateMessage(MessageVersion version, string action, object body) 121static public Message CreateMessage(MessageVersion version, string action, object body, XmlObjectSerializer serializer) 136static public Message CreateMessage(MessageVersion version, string action, XmlReader body) 141static public Message CreateMessage(MessageVersion version, string action, XmlDictionaryReader body) 156static public Message CreateMessage(MessageVersion version, string action, BodyWriter body) 171static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader, BodyWriter body) 186static public Message CreateMessage(MessageVersion version, string action) 196static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader) 206static public Message CreateMessage(XmlReader envelopeReader, int maxSizeOfHeaders, MessageVersion version) 211static public Message CreateMessage(XmlDictionaryReader envelopeReader, int maxSizeOfHeaders, MessageVersion version) 223Message message = new StreamedMessage(envelopeReader, maxSizeOfHeaders, version); 227static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, string action) 247static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, object detail, string action) 267static public Message CreateMessage(MessageVersion version, MessageFault fault, string action) 377internal void InitializeReply(Message request) 618Message.ReadFromBodyContentsToEnd(reader, Version.Envelope); 658Message.ReadFromBodyContentsToEnd(reader, envelopeVersion); 875private Message _message; 878public OnWriteMessageAsyncResult(XmlDictionaryWriter writer, Message message, AsyncCallback callback, object state) 991_isFault = Message.IsFaultStartElement(reader, version); 1279return Message.ReadStartBody(reader, Version.Envelope, out _isFault, out _isEmpty);
System\ServiceModel\Channels\MessageBuffer.cs (8)
30Message message = CreateMessage(); 46public abstract Message CreateMessage(); 65public DefaultMessageBuffer(Message message, XmlBuffer msgBuffer) 117public override Message CreateMessage() 124Message msg; 131msg = Message.CreateMessage(_msgBuffer.GetReader(0), int.MaxValue, _version); 245public override Message CreateMessage() 304public override Message CreateMessage()
System\ServiceModel\Channels\MessageEncoder.cs (17)
35public Message ReadMessage(Stream stream, int maxSizeOfHeaders) 40public virtual ValueTask<Message> ReadMessageAsync(Stream stream, int maxSizeOfHeaders, string contentType) 42return new ValueTask<Message>(ReadMessage(stream, maxSizeOfHeaders, contentType)); 45public virtual ValueTask<Message> ReadMessageAsync(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 47return new ValueTask<Message>(ReadMessage(buffer, bufferManager, contentType)); 50public abstract Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType); 52public Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager) 54Message message = ReadMessage(buffer, bufferManager, null); 58public abstract Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType); 96internal virtual async Task<Message> ReadMessageAsync(Stream stream, BufferManager bufferManager, int maxBufferSize, string contentType, CancellationToken cancellationToken) 106public abstract void WriteMessage(Message message, Stream stream); 108public virtual IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state) 118public ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager) 123public abstract ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, 126public virtual ValueTask WriteMessageAsync(Message message, Stream stream) 132public virtual ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, 240internal void ThrowIfMismatchedMessageVersion(Message message)
System\ServiceModel\Channels\MessageFault.cs (1)
75public static MessageFault CreateFault(Message message, int maxBufferSize)
System\ServiceModel\Channels\MessageHeaders.cs (2)
551public void CopyHeaderFrom(Message message, int headerIndex) 603public void CopyHeadersFrom(Message message)
System\ServiceModel\Channels\MtomMessageEncoder.cs (12)
362public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 381Message message = new BufferedMessage(messageData, messageState); 397public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 411Message message = Message.CreateMessage(reader, maxSizeOfHeaders, _version); 424public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 429public override ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 449private ArraySegment<byte> WriteMessageInternal(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset, string startInfo, string boundary, string startUri) 508public override void WriteMessage(Message message, Stream stream) 524public override ValueTask WriteMessageAsync(Message message, Stream stream) 529public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state) 539private async ValueTask WriteMessageInternalAsync(Message message, Stream stream, string startInfo, string boundary, string startUri)
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\ReliableChannelBinder.cs (16)
169protected virtual void AddOutputHeaders(Message message) 544protected virtual Task OnSendAsync(TChannel channel, Message message, TimeSpan timeout) 601public Task SendAsync(Message message, TimeSpan timeout) 606public async Task SendAsync(Message message, TimeSpan timeout, MaskingMode maskingMode) 807protected bool ValidateOutputOperation(Message message, TimeSpan timeout, MaskingMode maskingMode) 828protected RequestContext WrapMessage(Message message) 857public BinderRequestContext(ReliableChannelBinder<TChannel> binder, Message message) 1876public MessageRequestContext(ReliableChannelBinder<TChannel> binder, Message message) 1889protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1903protected override void OnReply(Message message, TimeSpan timeout) 1917RequestContext innerContext, Message message) 1933protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, 1967private async Task OnReplyAsync(Message message, TimeSpan timeout) 1995protected override void OnReply(Message message, TimeSpan timeout) 2017Message message = null; 2029(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(channel.BeginTryReceive, channel.EndTryReceive, timeout, null);
System\ServiceModel\Channels\ReliableMessagingHelpers.cs (62)
443public static bool AddressReply(Message message, Message faultMessage) 472public abstract Task SendFaultAsync(IReliableChannelBinder binder, RequestContext requestContext, Message faultMessage); 584protected abstract TState GetState(RequestContext requestContext, Message faultMessage); 627public override async Task SendFaultAsync(IReliableChannelBinder binder, RequestContext requestContext, Message faultMessage) 666public FaultState(RequestContext requestContext, Message faultMessage) 672public Message FaultMessage { get; } 701protected override FaultState GetState(RequestContext requestContext, Message faultMessage) 708internal class SendFaultHelper : TypedFaultHelper<Message> 715protected override void AbortState(Message message, bool isOnAbortThread) 724protected override async Task SendFaultAsync(IReliableChannelBinder binder, Message message, TimeSpan timeout) 730protected override Message GetState(RequestContext requestContext, Message faultMessage) 809private Message CreateRequestMessage() 811Message request = Message.CreateMessage(messageVersion, messageAction, messageBody); 912protected abstract Task<Message> OnRequestAsync(Message request, TimeSpan timeout, bool last); 914public async Task<Message> RequestAsync(TimeSpan timeout) 923Message request = null; 924Message reply = null; 985private bool ValidateReply(Message response) 1020private Message GetReply(Message reply, bool last) 1042protected override async Task<Message> OnRequestAsync(Message request, TimeSpan timeout, bool last) 1085protected override async Task<Message> OnRequestAsync(Message request, TimeSpan timeout, bool last) 1127private Message GetReply(bool last) 1157protected override async Task<Message> OnRequestAsync(Message request, TimeSpan timeout, bool last) 1673Message message, UniqueId id, SequenceRangeCollection ranges, bool final) 1679Message message, UniqueId id, SequenceRangeCollection ranges, bool final, int bufferRemaining) 1685internal static void AddAckRequestedHeader(ReliableMessagingVersion reliableMessagingVersion, Message message, 1691internal static void AddSequenceHeader(ReliableMessagingVersion reliableMessagingVersion, Message message, 1706internal static Message CreateAcknowledgmentMessage(MessageVersion version, 1710Message message = Message.CreateMessage(version, 1720internal static Message CreateAckRequestedMessage(MessageVersion messageVersion, 1723Message message = Message.CreateMessage(messageVersion, 1732internal static Message CreateCloseSequenceResponse(MessageVersion messageVersion, UniqueId messageId, 1737Message message = Message.CreateMessage(messageVersion, 1744internal static Message CreateCreateSequenceResponse(MessageVersion messageVersion, 1756Message responseMessage 1757= Message.CreateMessage(messageVersion, ActionHeader.Create( 1763internal static Message CreateCSRefusedCommunicationFault(MessageVersion messageVersion, 1769internal static Message CreateCSRefusedProtocolFault(MessageVersion messageVersion, 1775internal static Message CreateCSRefusedServerTooBusyFault(MessageVersion messageVersion, 1785private static Message CreateCSRefusedFault(MessageVersion messageVersion, 1813return Message.CreateMessage(messageVersion, fault, action); 1817ReliableMessagingVersion reliableMessagingVersion, Message message, IChannel innerChannel) 1884internal static Message CreateEndpointNotFoundFault(MessageVersion version, string reason) 1904return Message.CreateMessage(version, fault, version.Addressing.DefaultFaultAction); 1907internal static Message CreateTerminateMessage(MessageVersion version, 1913internal static Message CreateTerminateMessage(MessageVersion version, 1916Message message = Message.CreateMessage(version, 1925internal static Message CreateTerminateResponseMessage(MessageVersion version, UniqueId messageId, UniqueId sequenceId) 1927Message message = Message.CreateMessage(version,
System\ServiceModel\Channels\ReliableOutputConnection.cs (4)
69Message message = Message.CreateMessage(MessageVersion, WsrmFeb2005Strings.LastMessageAction); 94public Task<bool> AddMessageAsync(Message message, TimeSpan timeout, object state) 133private async Task<bool> InternalAddMessageAsync(Message message, TimeSpan timeout, object state, bool isLast)
System\ServiceModel\Channels\ReliableOutputSessionChannel.cs (21)
100Message closeReply = await _closeRequestor.RequestAsync(timeout); 235_session.OnLocalFault(exception, (Message)null, null); 265protected abstract Task OnConnectionSendAsync(Message message, TimeSpan timeout, bool saveHandledException, bool maskUnhandledException); 270using (Message message = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion, 299protected abstract Task OnConnectionSendMessageAsync(Message message, TimeSpan timeout, MaskingMode maskingMode); 353protected override async Task OnSendAsync(Message message, TimeSpan timeout) 359protected override void OnSend(Message message, TimeSpan timeout) 378using (Message request = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion, 385private void ProcessCloseOrTerminateReply(bool close, Message reply) 428protected async Task ProcessMessageAsync(Message message) 503Message response = WsrmUtilities.CreateTerminateResponseMessage( 581Message message = WsrmUtilities.CreateTerminateMessage(Settings.MessageVersion, 588Message terminateReply = await _terminateRequestor.RequestAsync(timeout); 655protected override async Task OnConnectionSendAsync(Message message, TimeSpan timeout, 659Message reply = null; 694protected override async Task OnConnectionSendMessageAsync(Message message, TimeSpan timeout, MaskingMode maskingMode) 696Message reply = await binder.RequestAsync(message, timeout, maskingMode); 734protected override async Task OnConnectionSendAsync(Message message, TimeSpan timeout, bool saveHandledException, bool maskUnhandledException) 766protected override Task OnConnectionSendMessageAsync(Message message, TimeSpan timeout, MaskingMode maskingMode) 823Message requestMessage = context.RequestMessage; 833ReliableSession.OnLocalFault(e, (Message)null, null);
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (17)
66private void AddAcknowledgementHeader(Message message, bool force) 80Message closeReply = await closeRequestor.RequestAsync(timeout); 94private Message CreateAckRequestedMessage() 96Message request = WsrmUtilities.CreateAckRequestedMessage(settings.MessageVersion, 102protected override IAsyncRequest CreateAsyncRequest(Message message) 244session.OnLocalFault(exception, (Message)null, null); 293Message reply = null; 400var message = CreateAckRequestedMessage(); 401var reply = await binder.RequestAsync(message, DefaultSendTimeout, MaskingMode.All); 408private void ProcessCloseOrTerminateReply(bool close, Message reply) 470private void ProcessReply(Message reply, IReliableRequest request, long requestSequenceNumber) 634Message terminateReply = await terminateRequestor.RequestAsync(timeout); 689void Set(Message reply); 700private Message _reply; 742public async Task SendRequestAsync(Message message, TimeoutHelper timeoutHelper) 749public void Set(Message reply) 768public async Task<Message> ReceiveReplyAsync(TimeoutHelper timeoutHelper)
System\ServiceModel\Channels\RequestChannel.cs (19)
203public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 208public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 213protected abstract IAsyncRequest CreateAsyncRequest(Message message); 215public Message EndRequest(IAsyncResult result) 217return result.ToApmEnd<Message>(); 220public Message Request(Message message) 225public Message Request(Message message, TimeSpan timeout) 230public Task<Message> RequestAsync(Message message) 235private async Task<Message> RequestAsyncInternal(Message message, TimeSpan timeout) 241public async Task<Message> RequestAsync(Message message, TimeSpan timeout) 261Message reply; 295protected virtual void AddHeadersTo(Message message) 313Task SendRequestAsync(Message message, TimeoutHelper timeoutHelper); 314Task<Message> ReceiveReplyAsync(TimeoutHelper timeoutHelper);
System\ServiceModel\Channels\RequestContext.cs (5)
11public abstract Message RequestMessage { get; } 18public abstract void Reply(Message message); 19public abstract void Reply(Message message, TimeSpan timeout); 20public abstract IAsyncResult BeginReply(Message message, AsyncCallback callback, object state); 21public abstract IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state);
System\ServiceModel\Channels\RequestContextBase.cs (11)
14private Message _requestMessage; 19protected RequestContextBase(Message requestMessage, TimeSpan defaultCloseTimeout, TimeSpan defaultSendTimeout) 26public void ReInitialize(Message requestMessage) 36public override Message RequestMessage 49protected void SetRequestMessage(Message requestMessage) 176protected abstract void OnReply(Message message, TimeSpan timeout); 177protected abstract IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state); 220public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state) 225public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 243public override void Reply(Message message) 248public override void Reply(Message message, TimeSpan timeout)
System\ServiceModel\Channels\RequestReplyCorrelator.cs (12)
22void IRequestReplyCorrelator.Add<T>(Message request, T state) 42T IRequestReplyCorrelator.Find<T>(Message reply, bool remove) 76private UniqueId GetRelatesTo(Message reply) 87internal static bool AddressReply(Message reply, Message request) 93internal static bool AddressReply(Message reply, ReplyToInfo info) 128internal static ReplyToInfo ExtractReplyToInfo(Message message) 133internal static void PrepareRequest(Message request) 149internal static void PrepareReply(Message reply, UniqueId messageId) 169internal static void PrepareReply(Message reply, Message request) 193internal ReplyToInfo(Message message)
System\ServiceModel\Channels\SecurityChannelFactory.cs (40)
267protected bool TryGetSecurityFaultException(Message faultMessage, out Exception faultException) 342public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 347public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 357public Task SendAsync(Message message) 362public async Task SendAsync(Message message, TimeSpan timeout) 378public void Send(Message message) 383public void Send(Message message, TimeSpan timeout) 412public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 417public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 422public Message EndRequest(IAsyncResult result) 424return result.ToApmEnd<Message>(); 427public Message Request(Message message) 432internal Message ProcessReply(Message reply, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 436Message unverifiedMessage = reply; 459public Task<Message> RequestAsync(Message message) 464public async Task<Message> RequestAsync(Message message, TimeSpan timeout) 471Message reply = await Task.Factory.FromAsync(InnerChannel.BeginRequest, InnerChannel.EndRequest, message, timeoutHelper.RemainingTime(), null); 476private async Task<Message> RequestAsyncInternal(Message message, TimeSpan timeout) 482public Message Request(Message message, TimeSpan timeout) 529public Task<Message> ReceiveAsync() 534public Task<Message> ReceiveAsync(TimeSpan timeout) 539public Message Receive() 544public Message Receive(TimeSpan timeout) 559public Message EndReceive(IAsyncResult result) 561return result.ToApmEnd<Message>(); 569public virtual bool EndTryReceive(IAsyncResult result, out Message message) 572(success, message) = result.ToApmEnd<(bool, Message)>(); 576internal Message ProcessMessage(Message message, TimeSpan timeout) 582Message unverifiedMessage = message; 607public async Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout) 616Message message; 623(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(InnerDuplexChannel.BeginTryReceive, InnerDuplexChannel.EndTryReceive, timeout, null); 634public bool TryReceive(TimeSpan timeout, out Message message)
System\ServiceModel\Channels\SecurityChannelFaultConverter.cs (2)
17protected override bool OnTryCreateException(Message message, MessageFault fault, out Exception exception) 37protected override bool OnTryCreateFaultMessage(Exception exception, out Message message)
System\ServiceModel\Channels\ServiceChannel.cs (16)
871internal void FireUnknownMessageReceived(Message message) 1014private void ThrowIfFaultUnderstood(Message reply, MessageFault fault, string action, MessageVersion version, FaultConverter faultConverter) 1172private void AddMessageProperties(Message message, OperationContext context) 1201public void Send(Message message) 1206public void Send(Message message, TimeSpan timeout) 1212public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 1217public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1228public Message Request(Message message) 1233public Message Request(Message message, TimeSpan timeout) 1236return (Message)Call(message.Headers.Action, false, operation, new object[] { message }, Array.Empty<object>(), timeout); 1239public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 1244public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1250public Message EndRequest(IAsyncResult result) 1252return (Message)EndCall(MessageHeaders.WildcardAction, Array.Empty<object>(), result);
System\ServiceModel\Channels\ServiceChannelProxy.cs (11)
745IAsyncResult IOutputChannel.BeginSend(Message message, AsyncCallback callback, object state) 750IAsyncResult IOutputChannel.BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 760void IOutputChannel.Send(Message message) 765void IOutputChannel.Send(Message message, TimeSpan timeout) 770Message IRequestChannel.Request(Message message) 775Message IRequestChannel.Request(Message message, TimeSpan timeout) 780IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state) 785IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 790Message IRequestChannel.EndRequest(IAsyncResult result)
System\ServiceModel\Channels\TextMessageEncoder.cs (11)
401public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 413Message message; 444public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 457Message message = Message.CreateMessage(reader, maxSizeOfHeaders, _version); 473public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 486public override void WriteMessage(Message message, Stream stream) 491public override ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 547private async Task WriteMessageAsyncInternal(Message message, Stream stream) 553public override async ValueTask WriteMessageAsync(Message message, Stream stream) 601public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
System\ServiceModel\Channels\TransmissionStrategy.cs (10)
20public MessageAttemptInfo(Message message, long sequenceNumber, int retryCount, object state) 27public Message Message { get; } 176public Task<(MessageAttemptInfo attemptInfo, bool success)> AddAsync(Message message, TimeSpan timeout, object state) 181public async Task<MessageAttemptInfo> AddLastAsync(Message message, TimeSpan timeout, object state) 193private MessageAttemptInfo AddToWindow(Message message, bool isLast, object state) 411private async Task<(MessageAttemptInfo attemptInfo, bool success)> InternalAddAsync(Message message, bool isLast, TimeSpan timeout, object state) 748public AsyncWaitQueueAdder(TransmissionStrategy strategy, Message message, bool isLast, object state) 860public void Add(Message message, long addTime, object state) 895public Message GetMessage(int index) 987public TransmissionInfo(Message message, long lastAttemptTime, object state)
System\ServiceModel\Channels\TransportOutputChannel.cs (1)
79protected override void AddHeadersTo(Message message)
System\ServiceModel\Channels\WsrmFault.cs (8)
124public Message CreateMessage(MessageVersion messageVersion, ReliableMessagingVersion reliableMessagingVersion) 149Message message = Message.CreateMessage(messageVersion, this, action); 177protected abstract void OnFaultMessageCreated(MessageVersion version, Message message); 218protected override void OnFaultMessageCreated(MessageVersion version, Message message) 376protected override void OnFaultMessageCreated(MessageVersion version, Message message) 402public static bool TryCreateFault11(ReliableMessagingVersion reliableMessagingVersion, Message message, 454public static bool TryCreateFault12(ReliableMessagingVersion reliableMessagingVersion, Message message,
System\ServiceModel\Channels\WsrmMessageInfo.cs (20)
17private Message _faultReply; 62public Message FaultReply 79public Message Message { get; private set; } 103public static Exception CreateInternalFaultException(Message faultReply, string message, Exception inner) 112Message faultReply = new WsrmRequiredFault(faultReason).CreateMessage(messageVersion, 120ReliableMessagingVersion reliableMessagingVersion, IChannel channel, ISession session, Message message) 126ReliableMessagingVersion reliableMessagingVersion, IChannel channel, ISession session, Message message, 561private static void ValidateMustUnderstand(MessageVersion version, Message message) 574private Message faultReply; 581public InternalFaultException(Message faultReply, string message, Exception inner) 594public Message FaultReply 618public static CloseSequenceInfo ReadMessage(MessageVersion messageVersion, Message message, 647public static CloseSequenceResponseInfo ReadMessage(MessageVersion messageVersion, Message message, 699Message message, MessageHeaders headers) 705Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 722Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 753Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, 769ReliableMessagingVersion reliableMessagingVersion, Message message, MessageHeaders headers) 813ReliableMessagingVersion reliableMessagingVersion, Message message, MessageHeaders headers) 845public static TerminateSequenceResponseInfo ReadMessage(MessageVersion messageVersion, Message message,
System\ServiceModel\ClientBase.cs (11)
1148void IOutputChannel.Send(Message message) 1153void IOutputChannel.Send(Message message, TimeSpan timeout) 1158IAsyncResult IOutputChannel.BeginSend(Message message, AsyncCallback callback, object state) 1163IAsyncResult IOutputChannel.BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1183Message IRequestChannel.Request(Message message) 1188Message IRequestChannel.Request(Message message, TimeSpan timeout) 1193IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state) 1198IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1203Message IRequestChannel.EndRequest(IAsyncResult result)
System\ServiceModel\Description\MessageDescription.cs (1)
120s_typeOfUntypedMessage = typeof(Message);
System\ServiceModel\Description\TypedMessageConverter.cs (6)
59public abstract Message ToMessage(object typedMessage); 60public abstract Message ToMessage(object typedMessage, MessageVersion version); 61public abstract object FromMessage(Message message); 90public override Message ToMessage(object typedMessage) 95public override Message ToMessage(object typedMessage, MessageVersion version) 103public override object FromMessage(Message message)
System\ServiceModel\Diagnostics\ActivityIdHeader.cs (3)
34internal static Guid ExtractActivityId(Message message) 64internal static bool ExtractActivityAndCorrelationId(Message message, out Guid activityId, out Guid correlationId) 101internal void AddTo(Message message)
System\ServiceModel\Diagnostics\EventTraceActivityHelper.cs (4)
16public static bool TryAttachActivity(Message message, EventTraceActivity activity) 30public static EventTraceActivity TryExtractActivity(Message message) 35public static EventTraceActivity TryExtractActivity(Message message, bool createIfNotExist) 89private static bool GetMessageId(Message message, out Guid guid)
System\ServiceModel\Diagnostics\MessageLogger.cs (3)
41internal static void LogMessage(ref Channels.Message message, int arg1) 55internal static void LogMessage(ref Channels.Message message, MessageLoggingSource messageLoggingSource) 67internal static void LogMessage(ref Channels.Message message, Xml.XmlDictionaryReader xmlDictionaryReader, MessageLoggingSource messageLoggingSource)
System\ServiceModel\Diagnostics\TraceUtility.cs (18)
34static internal void AddActivityHeader(Message message) 50static internal void AddAmbientActivityToMessage(Message message) 66static internal void CopyActivity(Message source, Message destination) 74internal static void SetActivity(Message message, ServiceModelActivity activity) 92internal static ServiceModelActivity ExtractActivity(Message message) 129internal static ServiceModelActivity ExtractAndRemoveActivity(Message message) 142static internal void MessageFlowAtMessageSent(Message message, EventTraceActivity eventTraceActivity) 165static internal void MessageFlowAtMessageReceived(Message message, OperationContext context, EventTraceActivity eventTraceActivity, bool createNewActivityId) 202internal static void ProcessIncomingMessage(Message message, EventTraceActivity eventTraceActivity) 229internal static void ProcessOutgoingMessage(Message message, EventTraceActivity eventTraceActivity) 343internal static void TraceDroppedMessage(Message message, EndpointDispatcher dispatcher) 348internal static Exception ThrowHelperWarning(Exception exception, Message message) 425internal static Guid ExtractActivityId(Message message) 455internal static Exception ThrowHelperError(Exception exception, Message message) 466internal static ArgumentException ThrowHelperArgument(string paramName, string message, Message msg) 471internal static ArgumentNullException ThrowHelperArgumentNull(string paramName, Message message) 529internal static void TransferFromTransport(Message message)
System\ServiceModel\Dispatcher\BufferedReceiveBinder.cs (7)
121public RequestContext CreateRequestContext(Message message) 126public void Send(Message message, TimeSpan timeout) 131public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 141public Message Request(Message message, TimeSpan timeout) 146public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 151public Message EndRequest(IAsyncResult result)
System\ServiceModel\Dispatcher\ChannelHandler.cs (14)
249Message message = request.RequestMessage; 407private ServiceChannel GetDatagramChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched) 432private EndpointDispatcher GetEndpointDispatcher(Message message, out bool addressMatched) 437private ServiceChannel GetSessionChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched) 859Message fault = Message.CreateMessage(_messageVersion, code, reason, action); 871Message fault = Message.CreateMessage(_messageVersion, code, reason, action); 875private void ReplyFailure(RequestContext request, Message fault, string action, string reason, FaultCode code) 919Message reply = faultInfo.Fault; 974private bool PrepareReply(RequestContext request, Message reply) 985Message requestMessage = null; 1279private EventTraceActivity TraceDispatchMessageStart(Message message) 1302public Message Reply;
System\ServiceModel\Dispatcher\ClientRuntime.cs (3)
432internal bool IsFault(ref Message reply) 450internal static bool IsMessageVersionNoneFault(ref Message message, int maxFaultSize) 469using (Message copy = buffer.CreateMessage())
System\ServiceModel\Dispatcher\DataContractSerializerOperationFormatter.cs (2)
165protected override void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest) 300protected override void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest)
System\ServiceModel\Dispatcher\DispatchOperationRuntime.cs (2)
241Message reply; 270reply = (Message)rpc.ReturnParameter;
System\ServiceModel\Dispatcher\DispatchRuntime.cs (5)
287internal DispatchOperationRuntime GetOperation(ref Message message) 356Message message = inputs[0] as Message; 397return Task.FromResult((object)Message.CreateMessage(message.Version, fault, message.Version.Addressing.DefaultFaultAction)); 528object IInstanceProvider.GetInstance(InstanceContext instanceContext, Message message)
System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (37)
248internal bool HandleRequestAsReply(Message message) 269private bool HandleRequestAsReplyCore(Message message) 314Message message; 335public RequestContext CreateRequestContext(Message message) 340public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 350public void Send(Message message, TimeSpan timeout) 355public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 398public Message EndRequest(IAsyncResult result) 419Message message; 440public Message Request(Message message, TimeSpan timeout) 481Message reply; 527private void RequestStarting(Message message, IDuplexRequest request) 635internal DuplexRequestContext(IDuplexChannel channel, Message request, DuplexChannelBinder binder) 650protected override void OnReply(Message message, TimeSpan timeout) 658protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 673public ReplyAsyncResult(DuplexRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state) 729void GotReply(Message reply); 734private Message _reply; 763internal Message WaitForReply(TimeSpan timeout) 780public void GotReply(Message reply) 810private Message _reply; 817internal AsyncDuplexRequest(Message message, DuplexChannelBinder parent, TimeSpan timeout, AsyncCallback callback, object state) 968internal Message End() 974public void GotReply(Message reply) 1057private InputQueue<Message> _pendingMessages; 1064_pendingMessages = new InputQueue<Message>(); 1225Message message = null; 1342public Message Receive() 1347public Message Receive(TimeSpan timeout) 1362public Message EndReceive(IAsyncResult result) 1367public bool TryReceive(TimeSpan timeout, out Message message) 1377public bool EndTryReceive(IAsyncResult result, out Message message) 1501public void Send(Message message) 1506public void Send(Message message, TimeSpan timeout) 1511public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 1516public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Dispatcher\EndpointDispatcherTable.cs (1)
52public EndpointDispatcher Lookup(Message message, out bool addressMatched)
System\ServiceModel\Dispatcher\ErrorBehavior.cs (7)
42rpc.FaultInfo.Fault = Message.CreateMessage(rpc.RequestVersion, messageFault, action); 104faultInfo.Fault = Message.CreateMessage(_messageVersion, fault, action); 124Message m = faultInfo.Fault; 137Message faultMessage; 149faultInfo.Fault = Message.CreateMessage(_messageVersion, MessageFault.CreateFault(ndfe.Code, ndfe.Reason, detail), ndfe.Action); 153faultInfo.Fault = Message.CreateMessage(_messageVersion, ndfe.CreateMessageFault(), ndfe.Action); 238internal static void ThrowAndCatch(Exception e, Message message)
System\ServiceModel\Dispatcher\ErrorHandlerFaultInfo.cs (1)
21public Message Fault { get; set; }
System\ServiceModel\Dispatcher\HeaderFilter.cs (1)
23Message message = buffer.CreateMessage();
System\ServiceModel\Dispatcher\IChannelBinder.cs (7)
25void Send(Message message, TimeSpan timeout); 26IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state); 29Message Request(Message message, TimeSpan timeout); 30IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state); 31Message EndRequest(IAsyncResult result); 37RequestContext CreateRequestContext(Message message);
System\ServiceModel\Dispatcher\IClientMessageFormatter.cs (2)
12Message SerializeRequest(MessageVersion messageVersion, object[] parameters); 13object DeserializeReply(Message message, object[] parameters);
System\ServiceModel\Dispatcher\IClientMessageInspector.cs (2)
12object BeforeSendRequest(ref Message request, IClientChannel channel); 13void AfterReceiveReply(ref Message reply, object correlationState);
System\ServiceModel\Dispatcher\IDispatchMessageFormatter.cs (2)
12void DeserializeRequest(Message message, object[] parameters); 13Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result);
System\ServiceModel\Dispatcher\IDispatchMessageInspector.cs (2)
12object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext); 13void BeforeSendReply(ref Message reply, object correlationState);
System\ServiceModel\Dispatcher\IErrorHandler.cs (1)
12void ProvideFault(Exception error, MessageVersion version, ref Message fault);
System\ServiceModel\Dispatcher\IInstanceContextProvider.cs (1)
12InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel);
System\ServiceModel\Dispatcher\IInstanceProvider.cs (1)
13object GetInstance(InstanceContext instanceContext, Message message);
System\ServiceModel\Dispatcher\IMessageFilterTable.cs (4)
13bool GetMatchingValue(Message message, out TFilterData value); 17bool GetMatchingValues(Message message, ICollection<TFilterData> results); 22bool GetMatchingFilter(Message message, out MessageFilter filter); 24bool GetMatchingFilters(Message message, ICollection<MessageFilter> results);
System\ServiceModel\Dispatcher\ImmutableDispatchRuntime.cs (6)
144Message originalReply = rpc.Reply; 145Message reply = originalReply; 333private void AddMessageProperties(Message message, OperationContext context, ServiceChannel replyChannel) 456internal DispatchOperationRuntime GetOperation(ref Message message) 463DispatchOperationRuntime GetOperation(ref Message request); 969public DispatchOperationRuntime GetOperation(ref Message request)
System\ServiceModel\Dispatcher\InputChannelBinder.cs (13)
69Message message; 82public RequestContext CreateRequestContext(Message message) 87public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 97public void Send(Message message, TimeSpan timeout) 104Message message; 117public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 122public Message EndRequest(IAsyncResult result) 127public Message Request(Message message, TimeSpan timeout) 147private RequestContext WrapMessage(Message message) 163internal InputRequestContext(Message request, InputChannelBinder binder) 177protected override void OnReply(Message message, TimeSpan timeout) 181protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Dispatcher\InstanceBehavior.cs (1)
78internal object GetInstance(InstanceContext instanceContext, Message request)
System\ServiceModel\Dispatcher\InstanceContextProviderBase.cs (1)
40public abstract InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel);
System\ServiceModel\Dispatcher\MessageFilter.cs (1)
42public abstract bool Match(Message message);
System\ServiceModel\Dispatcher\MessageOperationFormatter.cs (8)
28public object DeserializeReply(Message message, object[] parameters) 43public void DeserializeRequest(Message message, object[] parameters) 63public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 65if (!(result is Message)) 75return (Message)result; 78public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 85if (parameters.Length != 1 || !(parameters[0] is Message)) 90return (Message)parameters[0];
System\ServiceModel\Dispatcher\MessageRpc.cs (3)
43internal Message Request; 47internal Message Reply; 61internal MessageRpc(RequestContext requestContext, Message request, DispatchOperationRuntime operation,
System\ServiceModel\Dispatcher\OperationFormatter.cs (14)
51protected abstract void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest); 59protected abstract void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest); 110public object DeserializeReply(Message message, object[] parameters) 178public void DeserializeRequest(Message message, object[] parameters) 236private object DeserializeBodyContents(Message message, object[] parameters, bool isRequest) 266public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 292Message msg = new OperationFormatterMessage(this, messageVersion, 301public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 335Message msg = new OperationFormatterMessage(this, messageVersion, 450private void AddPropertiesToMessage(Message message, MessageDescription messageDescription, object[] parameters) 458private void AddPropertiesToMessageCore(Message message, MessageDescription messageDescription, object[] parameters) 473private void GetPropertiesFromMessage(Message message, MessageDescription messageDescription, object[] parameters) 481private void GetPropertiesFromMessageCore(Message message, MessageDescription messageDescription, object[] parameters) 841public override Message CreateMessage()
System\ServiceModel\Dispatcher\OutputChannelBinder.cs (7)
74public RequestContext CreateRequestContext(Message message) 79public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 89public void Send(Message message, TimeSpan timeout) 94public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 99public Message EndRequest(IAsyncResult result) 109public Message Request(Message message, TimeSpan timeout)
System\ServiceModel\Dispatcher\PerSessionInstanceContextProvider.cs (1)
18public override InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel)
System\ServiceModel\Dispatcher\PrimitiveOperationFormatter.cs (6)
441public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 453return Message.CreateMessage(messageVersion, GetActionHeader(messageVersion.Addressing), new PrimitiveRequestBodyWriter(parameters, this)); 456public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 468return Message.CreateMessage(messageVersion, GetReplyActionHeader(messageVersion.Addressing), new PrimitiveResponseBodyWriter(parameters, result, this)); 471public object DeserializeReply(Message message, object[] parameters) 520public void DeserializeRequest(Message message, object[] parameters)
System\ServiceModel\Dispatcher\ProxyOperationRuntime.cs (3)
128Message reply = rpc.Reply; 238rpc.Request = (Message)rpc.InputParameters[0]; 373static internal bool IsValidAction(Message message, string action)
System\ServiceModel\Dispatcher\ProxyRpc.cs (2)
23internal Message Request; 24internal Message Reply;
System\ServiceModel\Dispatcher\ReplyChannelBinder.cs (7)
72public RequestContext CreateRequestContext(Message message) 77public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 87public void Send(Message message, TimeSpan timeout) 92public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 97public Message EndRequest(IAsyncResult result) 107public Message Request(Message message, TimeSpan timeout)
System\ServiceModel\Dispatcher\RequestChannelBinder.cs (8)
70public RequestContext CreateRequestContext(Message message) 75public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 85public void Send(Message message, TimeSpan timeout) 90public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 95public Message EndRequest(IAsyncResult result) 105public Message Request(Message message, TimeSpan timeout) 110private void ValidateNullReply(Message message)
System\ServiceModel\Dispatcher\StreamFormatter.cs (3)
166internal void Deserialize(object[] parameters, ref object retVal, Message message) 280private Message _message; 288internal MessageBodyStream(Message message, string wrapperName, string wrapperNs, string elementName, string elementNs, bool isRequest)
System\ServiceModel\Dispatcher\XmlSerializerOperationFormatter.cs (2)
41protected override void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest) 144protected override void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest)
System\ServiceModel\EndpointAddress.cs (1)
268public void ApplyTo(Message message)
System\ServiceModel\InstanceContext.cs (1)
168public object GetServiceInstance(Message message)
System\ServiceModel\MessageHeaderException.cs (3)
34internal Message ProvideFault(MessageVersion messageVersion) 38Message message = System.ServiceModel.Channels.Message.CreateMessage(messageVersion, phf, AddressingVersion.WSAddressing10.FaultAction);
System\ServiceModel\MustUnderstandSoapException.cs (3)
32internal Message ProvideFault(MessageVersion messageVersion) 40Message message = System.ServiceModel.Channels.Message.CreateMessage(messageVersion, fault, faultAction);
System\ServiceModel\OperationContext.cs (10)
29private Message _clientReply; 32private Message _request; 77internal OperationContext(RequestContext requestContext, Message request, ServiceChannel channel) 174internal Message IncomingMessage 223Message message = _clientReply ?? _request; 239Message message = _clientReply ?? _request; 255Message message = _clientReply ?? _request; 356internal void ReInit(RequestContext requestContext, Message request, ServiceChannel channel) 373internal void SetClientReply(Message message, bool closeMessage) 375Message oldClientReply = null;
System\ServiceModel\ProtocolException.cs (2)
21internal static ProtocolException ReceiveShutdownReturnedNonNull(Message message) 45internal static ProtocolException OneWayOperationReturnedNonNull(Message message)
System\ServiceModel\Security\AcceleratedTokenProvider.cs (1)
187protected override BodyWriter GetNextOutgoingMessageBody(Message incomingMessage, AcceleratedTokenProviderState negotiationState)
System\ServiceModel\Security\InitiatorSessionSymmetricTransportSecurityProtocol.cs (3)
110internal void SetupDelayedSecurityExecution(string actor, ref Message message, SecurityToken signingToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters, 125protected override async Task<Message> SecureOutgoingMessageAtInitiatorAsync(Message message, string actor, TimeSpan timeout)
System\ServiceModel\Security\IssuanceTokenProviderBase.cs (11)
343static protected void ThrowIfFault(Message message, EndpointAddress target) 403protected abstract BodyWriter GetNextOutgoingMessageBody(Message incomingMessage, T negotiationState); 407private void PrepareRequest(Message nextMessage) 412private void PrepareRequest(Message nextMessage, RequestSecurityToken rst) 455Message nextOutgoingMessage = null; 456Message incomingMessage = null; 546private Message GetNextOutgoingMessage(Message incomingMessage, T negotiationState) 561Message nextMessage; 564nextMessage = Message.CreateMessage(MessageVersion, ActionHeader.Create(RequestSecurityTokenAction, MessageVersion.Addressing), nextMessageBody); 568nextMessage = Message.CreateMessage(MessageVersion, ActionHeader.Create(RequestSecurityTokenResponseAction, MessageVersion.Addressing), nextMessageBody);
System\ServiceModel\Security\ReceiveSecurityHeader.cs (2)
86protected ReceiveSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay, 234public Message ProcessedMessage
System\ServiceModel\Security\RequestSecurityToken.cs (1)
151public Message Message { get; set; }
System\ServiceModel\Security\SecurityAppliedMessage.cs (1)
31public SecurityAppliedMessage(Message messageToProcess, SendSecurityHeader securityHeader, bool signBody, bool encryptBody)
System\ServiceModel\Security\SecurityChannel.cs (1)
72protected void ThrowIfDisposedOrNotOpen(Message message)
System\ServiceModel\Security\SecurityHeader.cs (2)
23public SecurityHeader(Message message, 74protected Message Message { get; set; }
System\ServiceModel\Security\SecurityMessageProperty.cs (1)
193public static SecurityMessageProperty GetOrCreate(Message message)
System\ServiceModel\Security\SecurityProtocol.cs (16)
411private static void SetSecurityHeaderId(SendSecurityHeader securityHeader, Message message) 441protected SendSecurityHeader CreateSendSecurityHeader(Message message, string actor, SecurityProtocolFactory factory) 446protected SendSecurityHeader CreateSendSecurityHeaderForTransportProtocol(Message message, string actor, SecurityProtocolFactory factory) 451private SendSecurityHeader CreateSendSecurityHeader(Message message, string actor, SecurityProtocolFactory factory, bool requireMessageProtection) 470internal void AddMessageSupportingTokens(Message message, ref IList<SupportingTokenSpecification> supportingTokens) 492internal async Task<IList<SupportingTokenSpecification>> TryGetSupportingTokensAsync(SecurityProtocolFactory factory, EndpointAddress target, Uri via, Message message, TimeSpan timeout) 612public abstract Task<Message> SecureOutgoingMessageAsync(Message message, TimeSpan timeout); 615public virtual async Task<(SecurityProtocolCorrelationState, Message)> SecureOutgoingMessageAsync(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 620protected virtual void OnOutgoingMessageSecured(Message securedMessage) 624protected virtual void OnSecureOutgoingMessageFailure(Message message) 628public abstract void VerifyIncomingMessage(ref Message message, TimeSpan timeout); 631public virtual SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout, params SecurityProtocolCorrelationState[] correlationStates) 637protected virtual void OnIncomingMessageVerified(Message verifiedMessage) 641protected virtual void OnVerifyIncomingMessageFailure(Message message, Exception exception)
System\ServiceModel\Security\SecuritySessionClientSettings.cs (64)
307private Message _closeResponse; 575private Message PrepareCloseMessage() 586Message closeMessage = Message.CreateMessage(MessageVersion, ActionHeader.Create(Settings.SecurityStandardsManager.SecureConversationDriver.CloseAction, MessageVersion.Addressing), rst); 621Message closeMessage = PrepareCloseMessage(); 639Message message = null; 653private MessageFault GetProtocolFault(ref Message message, out bool isKeyRenewalFault, out bool isSessionAbortedFault) 661Message copy = buffer.CreateMessage(); 699private void ProcessCloseResponse(Message response) 742private void PrepareReply(Message request, Message reply) 765private bool DoesSkiClauseMatchSigningToken(SecurityContextKeyIdentifierClause skiClause, Message request) 775private void ProcessCloseMessage(Message message) 806Message response = null; 809response = Message.CreateMessage(message.Version, ActionHeader.Create(Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, message.Version.Addressing), rstr); 816response = Message.CreateMessage(message.Version, ActionHeader.Create(Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, message.Version.Addressing), rstrCollection); 831protected Message ProcessIncomingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, out MessageFault protocolFault) 891protected Message ProcessRequestContext(RequestContext requestContext, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 898Message message = requestContext.RequestMessage; 899Message unverifiedMessage = message; 1066protected async Task<(SecurityProtocolCorrelationState, Message)> SecureOutgoingMessageAsync(Message message, TimeSpan timeout) 1077protected void VerifyIncomingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 1120protected async Task<Message> ReceiveInternalAsync(TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 1133Message message = ProcessRequestContext(requestContext, timeoutHelper.RemainingTime(), correlationState); 1449Message message = await ReceiveInternalAsync(timeoutHelper.RemainingTime(), correlationState); 1462public Task<Message> RequestAsync(Message message) 1467Message IRequestChannel.Request(Message message) => ((IRequestChannel)this).Request(message, DefaultSendTimeout); 1469Message IRequestChannel.Request(Message message, TimeSpan timeout) => RequestAsync(message, timeout).WaitForCompletionNoSpin(); 1471IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state) => ((IRequestChannel)this).BeginRequest(message, DefaultSendTimeout, callback, state); 1473IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) => RequestAsync(message, timeout).ToApm(callback, state); 1475Message IRequestChannel.EndRequest(IAsyncResult result) => result.ToApmEnd<Message>(); 1477private Message ProcessReply(Message reply, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 1483Message unverifiedReply = reply; 1484Message processedReply = null; 1518public async Task<Message> RequestAsync(Message message, TimeSpan timeout) 1526Message reply = await ChannelBinder.RequestAsync(message, timeoutHelper.RemainingTime()); 1534private InputQueue<Message> _queue; 1540_queue = TraceUtility.CreateInputQueue<Message>(); 1577public Message Receive() => ReceiveAsync().GetAwaiter().GetResult(); 1579public Task<Message> ReceiveAsync() => ReceiveAsync(DefaultReceiveTimeout); 1581public Message Receive(TimeSpan timeout) => ReceiveAsync(timeout).GetAwaiter().GetResult(); 1583public Task<Message> ReceiveAsync(TimeSpan timeout) => InputChannel.HelpReceiveAsync(this, timeout); 1589public Message EndReceive(IAsyncResult result) => result.ToApmEnd<Message>(); 1593public bool EndTryReceive(IAsyncResult result, out Message message) 1596(success, message) = result.ToApmEnd<(bool, Message)>(); 1606public bool TryReceive(TimeSpan timeout, out Message message) 1613public async Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout) 1617(bool wasDequeued, Message message) = await _queue.TryDequeueAsync(timeout); 1626public void Send(Message message) => SendAsync(message).WaitForCompletionNoSpin(); 1628public Task SendAsync(Message message) => SendAsync(message, DefaultSendTimeout); 1630public void Send(Message message, TimeSpan timeout) => SendAsync(message, timeout).WaitForCompletionNoSpin(); 1632public async Task SendAsync(Message message, TimeSpan timeout) 1643public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) => SendAsync(message).ToApm(callback, state); 1645public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) => SendAsync(message, timeout).ToApm(callback, state); 1665Message message = await ReceiveInternalAsync(TimeSpan.MaxValue, null);
System\ServiceModel\Security\SecuritySessionSecurityTokenAuthenticator.cs (1)
25public override bool Match(Message message)
System\ServiceModel\Security\SecuritySessionSecurityTokenProvider.cs (15)
447private Message CreateRequest(SecuritySessionOperation operation, EndpointAddress target, SecurityToken currentToken, out object requestState) 463private GenericXmlSecurityToken ProcessReply(Message reply, SecuritySessionOperation operation, object requestState) 513using (Message requestMessage = CreateRequest(operation, target, currentToken, out requestState)) 519using (Message reply = await channel.RequestAsync(requestMessage, timeoutHelper.RemainingTime())) 579private void PrepareRequest(Message message) 595protected virtual Message CreateIssueRequest(EndpointAddress target, out object requestState) 601Message result = Message.CreateMessage(MessageVersion, ActionHeader.Create(IssueAction, MessageVersion.Addressing), rst); 606private GenericXmlSecurityToken ExtractToken(Message response, object requestState) 663protected virtual GenericXmlSecurityToken ProcessIssueResponse(Message response, object requestState) 669protected virtual Message CreateRenewRequest(EndpointAddress target, SecurityToken currentSessionToken, out object requestState) 676Message result = Message.CreateMessage(MessageVersion, ActionHeader.Create(RenewAction, MessageVersion.Addressing), rst); 684protected virtual GenericXmlSecurityToken ProcessRenewResponse(Message response, object requestState) 695protected static void ThrowIfFault(Message message, EndpointAddress target)
System\ServiceModel\Security\SecurityStandardsManager.cs (3)
129internal SendSecurityHeader CreateSendSecurityHeader(Message message, 136internal ReceiveSecurityHeader TryCreateReceiveSecurityHeader(Message message, 143internal bool DoesMessageContainSecurityHeader(Message message)
System\ServiceModel\Security\SecurityUtils.cs (2)
246public static ChannelBinding GetChannelBindingFromMessage(Message message) 965internal static void ThrowIfNegotiationFault(Message message, EndpointAddress target)
System\ServiceModel\Security\SecurityVerifiedMessage.cs (2)
31public SecurityVerifiedMessage(Message messageToProcess, ReceiveSecurityHeader securityHeader) 155if (Message.ReadStartBody(reader, InnerMessage.Version.Envelope, out _isDecryptedBodyFault, out _isDecryptedBodyEmpty))
System\ServiceModel\Security\SecurityVersion.cs (9)
69internal abstract ReceiveSecurityHeader CreateReceiveSecurityHeader(Message message, 76internal abstract SendSecurityHeader CreateSendSecurityHeader(Message message, 82internal bool DoesMessageContainSecurityHeader(Message message) 87internal int FindIndexOfSecurityHeader(Message message, string[] actors) 105internal ReceiveSecurityHeader TryCreateReceiveSecurityHeader(Message message, 162internal override SendSecurityHeader CreateSendSecurityHeader(Message message, 171internal override ReceiveSecurityHeader CreateReceiveSecurityHeader(Message message, 205internal override ReceiveSecurityHeader CreateReceiveSecurityHeader(Message message, 219internal override SendSecurityHeader CreateSendSecurityHeader(Message message,
System\ServiceModel\Security\SendSecurityHeader.cs (2)
40protected SendSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay, 405public Message SetupExecution()
System\ServiceModel\Security\TransportSecurityProtocol.cs (8)
23public override async Task<Message> SecureOutgoingMessageAsync(Message message, TimeSpan timeout) 52protected virtual async Task<Message> SecureOutgoingMessageAtInitiatorAsync(Message message, string actor, TimeSpan timeout) 59internal void SetUpDelayedSecurityExecution(ref Message message, string actor, 67public sealed override void VerifyIncomingMessage(ref Message message, TimeSpan timeout) 96protected void AttachRecipientSecurityProperty(Message message, IList<SecurityToken> basicTokens, IList<SecurityToken> endorsingTokens, 104protected virtual void VerifyIncomingMessageCore(ref Message message, TimeSpan timeout)
System\ServiceModel\Security\WSSecurityOneDotOneReceiveSecurityHeader.cs (1)
13public WSSecurityOneDotOneReceiveSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay,
System\ServiceModel\Security\WSSecurityOneDotOneSendSecurityHeader.cs (1)
13public WSSecurityOneDotOneSendSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay,
System\ServiceModel\Security\WSSecurityOneDotZeroReceiveSecurityHeader.cs (1)
13public WSSecurityOneDotZeroReceiveSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay,
System\ServiceModel\Security\WSSecurityOneDotZeroSendSecurityHeader.cs (1)
36public WSSecurityOneDotZeroSendSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay,
System\ServiceModel\UnknownMessageReceivedEventArgs.cs (2)
12internal UnknownMessageReceivedEventArgs(Message message) 17public Message Message { get; }
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);