7 types derived from Message
System.ServiceModel (5)
System\ServiceModel\Channels\ContentOnlyMessage.cs (1)
15abstract class ContentOnlyMessage : Message
System\ServiceModel\Channels\DelegatingMessage.cs (1)
9abstract class DelegatingMessage : Message
System\ServiceModel\Channels\Message.cs (2)
967class BodyWriterMessage : Message 1216abstract class ReceivedMessage : Message
System\ServiceModel\Security\ImpersonatingMessage.cs (1)
10sealed class ImpersonatingMessage : Message
System.ServiceModel.Channels (1)
System\ServiceModel\Channels\ByteStreamMessage.cs (1)
67class InternalByteStreamMessage : Message
System.ServiceModel.Web (1)
System\ServiceModel\Channels\HttpStreamMessage.cs (1)
15class HttpStreamMessage : Message
3051 references to Message
ComSvcConfig (5)
ComAdminWrapper.cs (1)
41static Assembly ListenerAssembly = typeof(Message).Assembly;
ComplusTypeValidator.cs (4)
35Type typeOfInterfaceResolver = typeof(Message).Assembly.GetType("System.ServiceModel.ComIntegration.TypeCacheManager"); 92Type typeOfInterfaceResolver = typeof(Message).Assembly.GetType("System.ServiceModel.ComIntegration.TypeCacheManager"); 168Type typeOfInterfaceResolver = typeof(Message).Assembly.GetType("System.ServiceModel.ComIntegration.TypeCacheManager"); 218Type typeOfInterfaceResolver = typeof(Message).Assembly.GetType("System.ServiceModel.ComIntegration.TypeCacheManager");
System.Data.Services (10)
System\Data\Services\DataService.cs (8)
359/// <returns>The response <see cref="Message"/>.</returns> 360public Message ProcessRequestForMessage(Stream messageBody) 372Message result = CreateMessage(MessageVersion.None, "", ((IDataServiceHost)httpHost).ResponseContentType, writer, this); 533/// Creates a <see cref="Message"/> that invokes the specified 541/// <returns>A new <see cref="Message"/>.</returns> 542private static Message CreateMessage(MessageVersion version, string action, string contentType, Action<Stream> writer, IDataService service) 550Message message = Message.CreateMessage(version, action, bodyWriter);
System\Data\Services\IRequestHandler.cs (2)
29/// <returns>The resulting <see cref="Message"/> for this request.</returns> 32Message ProcessRequestForMessage(Stream messageBody);
System.ServiceModel (2527)
System\ServiceModel\ActionMismatchAddressingException.cs (3)
46internal Message ProvideFault(MessageVersion messageVersion) 50Message message = System.ServiceModel.Channels.Message.CreateMessage(messageVersion, phf, messageVersion.Addressing.FaultAction);
System\ServiceModel\ActionNotSupportedException.cs (2)
20internal Message ProvideFault(MessageVersion messageVersion) 25return System.ServiceModel.Channels.Message.CreateMessage(
System\ServiceModel\Activation\AspNetEnvironment.cs (3)
222public virtual IAspNetMessageProperty GetHostingProperty(Message message) 228public virtual IAspNetMessageProperty GetHostingProperty(Message message, bool removeFromMessage) 235public virtual void PrepareMessageForDispatch(Message message)
System\ServiceModel\Channels\AddressHeaderCollection.cs (1)
66public void AddHeadersTo(Message message)
System\ServiceModel\Channels\BinaryMessageEncoder.cs (11)
612public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 649Message message; 686public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 707Message message = Message.CreateMessage(reader, maxSizeOfHeaders, factory.messageVersion); 723public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 838public override void WriteMessage(Message message, Stream stream) 921public void AddCompressedMessageProperties(Message message, string supportedCompressionTypes) 971CompressionFormat CheckCompressedWrite(Message message) 1421public Message TryCreateMessage(byte[] buffer, int offset, int size, BufferManager bufferManager, BufferedMessageData messageData) 1914public override Message CreateMessage()
System\ServiceModel\Channels\BufferedMessageWriter.cs (1)
27public ArraySegment<byte> WriteMessage(Message message, BufferManager bufferManager, int initialOffset, int maxSizeQuota)
System\ServiceModel\Channels\BufferedReceiveMessageProperty.cs (2)
59Message requestMessage = this.messageBuffer.CreateMessage(); 66public static bool TryGet(Message message, out BufferedReceiveMessageProperty property)
System\ServiceModel\Channels\BufferedRequestContext.cs (6)
25public override Message RequestMessage 49public void ReInitialize(Message requestMessage) 104public override void Reply(Message message) 109public override void Reply(Message message, TimeSpan timeout) 114public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state) 119public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\CallbackContextMessageProperty.cs (2)
122public static bool TryGet(Message message, out CallbackContextMessageProperty contextMessageProperty) 152public void AddOrReplaceInMessage(Message message)
System\ServiceModel\Channels\ChannelBindingMessageProperty.cs (2)
51public static bool TryGet(Message message, out ChannelBindingMessageProperty property) 80public void AddTo(Message message)
System\ServiceModel\Channels\ChannelBindingUtility.cs (1)
117public static void TryAddToMessage(ChannelBinding channelBindingToken, Message message, bool messagePropertyOwnsCleanup)
System\ServiceModel\Channels\ChannelDemuxer.cs (91)
148internal static void AbortMessage(Message message) 246protected abstract Message GetMessage(TInnerItem item); 341IChannelListener MatchListener(Message message) 603Message message = null; 1099class InputChannelDemuxer : DatagramChannelDemuxer<IInputChannel, Message> 1106protected override void AbortItem(Message message) 1118SingletonChannelListener<IInputChannel, InputChannel, Message> listener = new SingletonChannelListener<IInputChannel, InputChannel, Message>(filter, this); 1125SingletonChannelListener<IInputChannel, InputChannel, Message> singletonListener = (SingletonChannelListener<IInputChannel, InputChannel, Message>)listener; 1129protected override void EndpointNotFound(Message message) 1138protected override Message EndReceive(IAsyncResult result) 1143protected override void EnqueueAndDispatch(IChannelListener listener, Message message, Action dequeuedCallback, bool canDispatchOnThisThread) 1145SingletonChannelListener<IInputChannel, InputChannel, Message> singletonListener = (SingletonChannelListener<IInputChannel, InputChannel, Message>)listener; 1151SingletonChannelListener<IInputChannel, InputChannel, Message> singletonListener = (SingletonChannelListener<IInputChannel, InputChannel, Message>)listener; 1155protected override Message GetMessage(Message message) 1161class DuplexChannelDemuxer : DatagramChannelDemuxer<IDuplexChannel, Message> 1168protected override void AbortItem(Message message) 1180SingletonChannelListener<IDuplexChannel, DuplexChannel, Message> listener = new SingletonChannelListener<IDuplexChannel, DuplexChannel, Message>(filter, this); 1187SingletonChannelListener<IDuplexChannel, DuplexChannel, Message> singletonListener = (SingletonChannelListener<IDuplexChannel, DuplexChannel, Message>)listener; 1191protected override void EndpointNotFound(Message message) 1200protected override Message EndReceive(IAsyncResult result) 1205protected override void EnqueueAndDispatch(IChannelListener listener, Message message, Action dequeuedCallback, bool canDispatchOnThisThread) 1207SingletonChannelListener<IDuplexChannel, DuplexChannel, Message> singletonListener = (SingletonChannelListener<IDuplexChannel, DuplexChannel, Message>)listener; 1213SingletonChannelListener<IDuplexChannel, DuplexChannel, Message> singletonListener = (SingletonChannelListener<IDuplexChannel, DuplexChannel, Message>)listener; 1217protected override Message GetMessage(Message message) 1222class DuplexChannelAcceptor : SingletonChannelAcceptor<IDuplexChannel, DuplexChannel, Message> 1237protected override void OnTraceMessageReceived(Message message) 1267protected override void OnSend(Message message, TimeSpan timeout) 1272protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1320SingletonChannelListener<IInputChannel, InputChannel, Message> listener = new SingletonChannelListener<IInputChannel, InputChannel, Message>(filter, this); 1338SingletonChannelListener<IInputChannel, InputChannel, Message> inputListener = listener as SingletonChannelListener<IInputChannel, InputChannel, Message>; 1456SingletonChannelListener<IInputChannel, InputChannel, Message> inputListener = listener as SingletonChannelListener<IInputChannel, InputChannel, Message>; 1490SingletonChannelListener<IInputChannel, InputChannel, Message> inputListener = listener as SingletonChannelListener<IInputChannel, InputChannel, Message>; 1507protected override Message GetMessage(RequestContext request) 1686protected abstract Message GetMessage(TInnerItem item); 1955InputQueueChannelListener<TInnerChannel> MatchListener(Message message) 2255Message message = this.GetMessage(item); 2686class InputSessionChannelDemuxer : SessionChannelDemuxer<IInputSessionChannel, Message> 2693protected override void AbortItem(Message message) 2708protected override IInputSessionChannel CreateChannel(ChannelManagerBase channelManager, IInputSessionChannel innerChannel, Message firstMessage) 2713protected override void EndpointNotFound(IInputSessionChannel channel, Message message) 2723protected override Message EndReceive(IInputSessionChannel channel, IAsyncResult result) 2728protected override Message GetMessage(Message message) 2736public InputSessionChannelWrapper(ChannelManagerBase channelManager, IInputSessionChannel innerChannel, Message firstMessage) 2752class DuplexSessionChannelDemuxer : SessionChannelDemuxer<IDuplexSessionChannel, Message> 2759protected override void AbortItem(Message message) 2774protected override IDuplexSessionChannel CreateChannel(ChannelManagerBase channelManager, IDuplexSessionChannel innerChannel, Message firstMessage) 2823protected override void EndpointNotFound(IDuplexSessionChannel channel, Message message) 2875protected override Message EndReceive(IDuplexSessionChannel channel, IAsyncResult result) 2880protected override Message GetMessage(Message message) 2888public Message message; 2890public ChannelAndMessageAsyncState(IChannel channel, Message message) 2900public DuplexSessionChannelWrapper(ChannelManagerBase channelManager, IDuplexSessionChannel innerChannel, Message firstMessage) 2925public void Send(Message message) 2930public void Send(Message message, TimeSpan timeout) 2935public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 2940public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 3080protected override Message GetMessage(RequestContext request) 3199class InputChannelWrapper : ChannelWrapper<IInputChannel, Message>, IInputChannel 3201public InputChannelWrapper(ChannelManagerBase channelManager, IInputChannel innerChannel, Message firstMessage) 3227Message message = this.GetFirstItem(); 3234public Message Receive() 3236Message message = this.GetFirstItem(); 3242public Message Receive(TimeSpan timeout) 3244Message message = this.GetFirstItem(); 3252Message message = this.GetFirstItem(); 3260Message message = this.GetFirstItem(); 3266public Message EndReceive(IAsyncResult result) 3273public bool TryReceive(TimeSpan timeout, out Message message) 3283Message message = this.GetFirstItem(); 3289public bool EndTryReceive(IAsyncResult result, out Message message) 3856Message message; 3858public DuplexSessionDemuxFailureAsyncResult(IChannelDemuxFailureHandler demuxFailureHandler, IDuplexSessionChannel channel, Message message, AsyncCallback callback, object state) 3957void HandleDemuxFailure(Message message); 3959IAsyncResult BeginHandleDemuxFailure(Message message, RequestContext faultContext, AsyncCallback callback, object state); 3960IAsyncResult BeginHandleDemuxFailure(Message message, IOutputChannel faultContext, AsyncCallback callback, object state);
System\ServiceModel\Channels\ChannelReliableSession.cs (8)
30Message terminatingFault; 248Message faultMessage = (fault == null) ? null : fault.CreateMessage(this.settings.MessageVersion, 253public void OnLocalFault(Exception e, Message faultMessage, RequestContext context) 380this.OnLocalFault(e, (Message)null, null); 425this.OnLocalFault(throwException ? null : e, (Message)null, context); 832Message response = this.requestor.Request(timeout); 854void ProcessCreateSequenceResponse(Message response, DateTime start) 1066Message response = this.session.requestor.EndRequest(result);
System\ServiceModel\Channels\ClientContextProtocol.cs (5)
79public override void OnIncomingMessage(Message message) 115public override void OnOutgoingMessage(Message message, RequestContext requestContext) 288ContextMessageProperty OnReceiveHttpCookies(Message message) 320ContextMessageProperty OnReceiveSoapContextHeader(Message message) 336void OnSendHttpCookies(Message message, ContextMessageProperty context)
System\ServiceModel\Channels\ClientReliableChannelBinder.cs (31)
91public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, 97public IAsyncResult BeginRequest(Message message, TimeSpan timeout, MaskingMode maskingMode, 158public Message EndRequest(IAsyncResult result) 196protected virtual IAsyncResult OnBeginRequest(TChannel channel, Message message, 216protected virtual Message OnEndRequest(TChannel channel, MaskingMode maskingMode, 226protected virtual Message OnRequest(TChannel channel, Message message, TimeSpan timeout, 232public Message Request(Message message, TimeSpan timeout) 237public Message Request(Message message, TimeSpan timeout, MaskingMode maskingMode) 355protected override IAsyncResult OnBeginSend(TDuplexChannel channel, Message message, 375Message message; 389protected override void OnSend(TDuplexChannel channel, Message message, 398Message message; 498InputQueue<Message> inputMessages; 518Message message; 524protected void EnqueueMessageIfNotNull(Message message) 532InputQueue<Message> GetInputMessages() 548this.inputMessages = TraceUtility.CreateInputQueue<Message>(); 576Message message, TimeSpan timeout, MaskingMode maskingMode, 582protected override IAsyncResult OnBeginSend(TRequestChannel channel, Message message, 588protected override Message OnEndRequest(TRequestChannel channel, 596Message message = channel.EndRequest(result); 600protected override Message OnRequest(TRequestChannel channel, Message message, 606protected override void OnSend(TRequestChannel channel, Message message, 623Message message; 633Message reply; 642ClientReliableChannelBinder<TChannel> binder, TChannel channel, Message message, 649public static Message End(IAsyncResult result)
System\ServiceModel\Channels\ContextChannelRequestContext.cs (9)
33public override Message RequestMessage 43public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 48public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state) 68public override void Reply(Message message, TimeSpan timeout) 71Message replyMessage = message; 105public override void Reply(Message message) 117Message message; 118Message replyMessage; 121public ReplyAsyncResult(Message message, ContextChannelRequestContext context, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\ContextDuplexSessionChannel.cs (8)
69public Message EndReceive(IAsyncResult result) 71Message message = this.InnerChannel.EndReceive(result); 79public bool EndTryReceive(IAsyncResult result, out Message message) 94public Message Receive(TimeSpan timeout) 96Message message = this.InnerChannel.Receive(timeout); 104public Message Receive() 106Message message = this.InnerChannel.Receive(); 114public bool TryReceive(TimeSpan timeout, out Message message)
System\ServiceModel\Channels\ContextExchangeCorrelationHelper.cs (4)
14public static void AddIncomingContextCorrelationData(Message message) 19public static void AddOutgoingCorrelationCallbackData(CorrelationCallbackMessageProperty callback, Message message, bool client) 31public static string GetContextCorrelationData(Message message) 57public static string GetCallbackContextCorrelationData(Message message)
System\ServiceModel\Channels\ContextInputChannelBase.cs (9)
48public Message EndReceive(IAsyncResult result) 50Message message = this.InnerChannel.EndReceive(result); 55public bool EndTryReceive(IAsyncResult result, out Message message) 73public Message Receive(TimeSpan timeout) 75Message message = this.InnerChannel.Receive(timeout); 80public Message Receive() 82Message message = this.InnerChannel.Receive(); 87public bool TryReceive(TimeSpan timeout, out Message message) 105void ProcessContextHeader(Message message)
System\ServiceModel\Channels\ContextMessageHeader.cs (1)
48public static ContextMessageProperty GetContextFromHeaderIfExists(Message message)
System\ServiceModel\Channels\ContextMessageProperty.cs (2)
70public static bool TryGet(Message message, out ContextMessageProperty contextMessageProperty) 100public void AddOrReplaceInMessage(Message message)
System\ServiceModel\Channels\ContextOutputChannelBase.cs (8)
38public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 43public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 65public void Send(Message message, TimeSpan timeout) 69Message sendMessage = message; 97public void Send(Message message) 108Message message; 109Message sendMessage; 112public SendAsyncResult(Message message, ContextOutputChannelBase<TChannel> channel, ContextProtocol contextProtocol,
System\ServiceModel\Channels\ContextProtocol.cs (3)
36public abstract void OnIncomingMessage(Message message); 38public abstract void OnOutgoingMessage(Message message, RequestContext requestContext); 40protected void OnSendSoapContextHeader(Message message, ContextMessageProperty context)
System\ServiceModel\Channels\ContextRequestChannelBase.cs (15)
32public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 38public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 43public Message EndRequest(IAsyncResult result) 45Message message = RequestAsyncResult.End(result); 67public Message Request(Message message, TimeSpan timeout) 71Message requestMessage = message; 83Message response = null; 103public Message Request(Message message) 115Message message; 116Message replyMessage; 117Message requestMessage; 120public RequestAsyncResult(Message message, IRequestChannel channel, TimeSpan timeout, AsyncCallback callback, object state) 161public static Message End(IAsyncResult result)
System\ServiceModel\Channels\CorrelationCallbackMessageProperty.cs (9)
71public static bool TryGet(Message message, out CorrelationCallbackMessageProperty property) 123public IAsyncResult BeginFinalizeCorrelation(Message message, TimeSpan timeout, AsyncCallback callback, object state) 146public Message EndFinalizeCorrelation(IAsyncResult result) 156public Message FinalizeCorrelation(Message message, TimeSpan timeout) 177protected abstract IAsyncResult OnBeginFinalizeCorrelation(Message message, TimeSpan timeout, AsyncCallback callback, object state); 178protected abstract Message OnEndFinalizeCorrelation(IAsyncResult result); 179protected abstract Message OnFinalizeCorrelation(Message message, TimeSpan timeout);
System\ServiceModel\Channels\CorrelationDataMessageProperty.cs (2)
78public static bool TryGet(Message message, out CorrelationDataMessageProperty property) 101public static void AddData(Message message, string name, Func<string> dataProvider)
System\ServiceModel\Channels\CorrelationMessageProperty.cs (1)
118public static bool TryGet(Message message, out CorrelationMessageProperty property)
System\ServiceModel\Channels\CreateSequence.cs (5)
77Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 98Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 138Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 153Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 162Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
System\ServiceModel\Channels\DatagramAdapter.cs (22)
754class InputDatagramAdapterListener : DatagramAdapterListenerBase<IInputChannel, IInputSessionChannel, Message> 756SingletonChannelAcceptor<IInputChannel, InputChannel, Message> acceptor; 773protected override Message CallEndReceive(IInputSessionChannel channel, IAsyncResult result) 778protected override void Enqueue(Message message, Action callback) 1155public void Send(Message message) 1160public void Send(Message message, TimeSpan timeout) 1199public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 1204public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1217Message message; 1221public SendAsyncResult(OutputDatagramAdapterChannel adapter, Message message, TimeSpan timeout, AsyncCallback callback, object state) 1385public Message Request(Message request) 1390public Message Request(Message request, TimeSpan timeout) 1395Message reply = null; 1432public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 1437public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1442public Message EndRequest(IAsyncResult result) 1450Message message; 1451Message reply = null; 1455public RequestAsyncResult(RequestDatagramAdapterChannel adapter, Message message, TimeSpan timeout, AsyncCallback callback, object state) 1576public static Message End(IAsyncResult result)
System\ServiceModel\Channels\DelegatingMessage.cs (3)
11Message innerMessage; 13protected DelegatingMessage(Message innerMessage) 50protected Message InnerMessage
System\ServiceModel\Channels\DoneReceivingAsyncResult.cs (1)
17internal static bool End(DoneReceivingAsyncResult result, out Message message)
System\ServiceModel\Channels\DuplexChannel.cs (13)
11abstract class DuplexChannel : InputQueueChannel<Message>, IDuplexChannel 29public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 34public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 69protected abstract void OnSend(Message message, TimeSpan timeout); 71protected virtual IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 82public void Send(Message message) 87public void Send(Message message, TimeSpan timeout) 102protected virtual void AddHeadersTo(Message message) 106public Message Receive() 111public Message Receive(TimeSpan timeout) 138public Message EndReceive(IAsyncResult result) 143public bool TryReceive(TimeSpan timeout, out Message message) 163public bool EndTryReceive(IAsyncResult result, out Message 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\FramingChannels.cs (6)
75protected override void PrepareMessage(Message message) 84protected override void OnSendCore(Message message, TimeSpan timeout) 105protected override AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, WaitCallback callback, object state) 111protected override AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, WaitCallback callback, object state) 117protected override ArraySegment<byte> EncodeMessage(Message message) 375protected override void PrepareMessage(Message message)
System\ServiceModel\Channels\HttpChannelFactory.cs (14)
592static internal void TraceResponseReceived(HttpWebResponse response, Message message, object receiver) 814void ApplyManualAddressing(ref EndpointAddress to, ref Uri via, Message message) 1087protected override IAsyncRequest CreateAsyncRequest(Message message, AsyncCallback callback, object state) 1102protected override IRequest CreateRequest(Message message) 1194private string GetConnectionGroupPrefix(Message message) 1209public void SendRequest(Message message, TimeSpan timeout) 1216Message request = message; 1291public Message WaitForReply(TimeSpan timeout) 1340Message replyMessage = null; 1395Message message; 1396Message requestMessage; 1397Message replyMessage; 1441public void BeginSendRequest(Message message, TimeSpan timeout) 1753public Message End()
System\ServiceModel\Channels\HttpChannelHelpers.cs (32)
152Message DecodeBufferedMessage(ArraySegment<byte> buffer, Stream inputStream) 183Message ReadBufferedMessage(Stream inputStream) 210Message ReadChunkedBufferedMessage(Stream inputStream) 223Message ReadStreamedMessage(Stream inputStream) 238protected abstract void AddProperties(Message message); 240void ApplyChannelBinding(Message message) 249Exception ProcessHttpAddressing(Message message) 437public Message EndParseIncomingMessage(IAsyncResult result, out Exception requestException) 442Message message = ParseMessageAsyncResult.End(result, out requestException); 473public Message ParseIncomingMessage(out Exception requestException) 478public Message ParseIncomingMessage(HttpRequestMessage httpRequestMessage, out Exception requestException) 480Message message = null; 552Message ReadBufferedMessage(HttpRequestMessage httpRequestMessage) 556Message message; 638Message message; 801public static Message End(IAsyncResult result, out Exception requestException) 884protected override void AddProperties(Message message) 1074Message message; 1087protected HttpOutput(IHttpTransportFactorySettings settings, Message message, bool isRequest, bool supportsConcurrentIO) 1236public void ConfigureHttpResponseMessage(Message message, HttpResponseMessage httpResponseMessage, HttpResponseMessageProperty responseProperty) 1370protected virtual bool PrepareHttpSend(Message message) 1438private static void EnsureEventTraceActivity(Message message) 1461ArraySegment<byte> SerializeBufferedMessage(Message message) 1467ArraySegment<byte> SerializeBufferedMessage(Message message, bool shouldRecycleBuffer) 2365internal static HttpOutput CreateHttpOutput(HttpWebRequest httpWebRequest, IHttpTransportFactorySettings settings, Message message, bool enableChannelBindingSupport) 2370internal static HttpOutput CreateHttpOutput(HttpListenerResponse httpListenerResponse, IHttpTransportFactorySettings settings, Message message, string httpMethod) 2381public WebRequestHttpOutput(HttpWebRequest httpWebRequest, IHttpTransportFactorySettings settings, Message message, bool enableChannelBindingSupport) 2507protected override bool PrepareHttpSend(Message message) 2912public ListenerResponseHttpOutput(HttpListenerResponse listenerResponse, IHttpTransportFactorySettings settings, Message message, string httpMethod) 2944protected override bool PrepareHttpSend(Message message) 3292HttpWebResponse webResponse, Message replyMessage) 4209protected override void AddProperties(Message message)
System\ServiceModel\Channels\HttpPipeline.cs (18)
118public abstract void SendReply(Message message, TimeSpan timeout); 120public virtual AsyncCompletionResult SendAsyncReply(Message message, Action<object, HttpResponseMessage> asyncSendCallback, object state) 145protected abstract Message EndParseIncomingMesssage(IAsyncResult result, out Exception requestException); 147protected abstract void OnParseComplete(Message message, Exception requestException); 206protected HttpOutput GetHttpOutput(Message message) 227public override void SendReply(Message message, TimeSpan timeout) 262protected override Message EndParseIncomingMesssage(IAsyncResult result, out Exception requestException) 269protected override void OnParseComplete(Message message, Exception requestException) 283protected virtual void SendReplyCore(Message message, TimeSpan timeout) 360protected override void SendReplyCore(Message message, TimeSpan timeout) 435public override void SendReply(Message message, TimeSpan timeout) 475public override AsyncCompletionResult SendAsyncReply(Message message, Action<object, HttpResponseMessage> asyncSendCallback, object state) 561protected override Message EndParseIncomingMesssage(IAsyncResult result, out Exception requestException) 566protected override void OnParseComplete(Message message, Exception requestException) 706HttpResponseMessage CreateHttpResponseMessage(Message message) 720void CompleteChannelModelIntegrationHandlerTask(Message replyMessage) 772public override void SendReply(Message message, TimeSpan timeout) 908Message message = this.pipeline.EndParseIncomingMesssage(result, out requestException);
System\ServiceModel\Channels\HttpRequestContext.cs (17)
33protected HttpRequestContext(HttpChannelListener listener, Message requestMessage, EventTraceActivity eventTraceActivity) 124public abstract HttpOutput GetHttpOutput(Message message); 127public HttpOutput GetHttpOutputCore(Message message) 175internal void SetMessage(Message message, Exception requestException) 198void TraceHttpMessageReceived(Message message) 252bool PrepareReply(ref Message message) 312protected override void OnReply(Message message, TimeSpan timeout) 315Message responseMessage = message; 343Message message, TimeSpan timeout, AsyncCallback callback, object state) 417using (Message ackMessage = CreateAckMessage(statusCode, statusDescription)) 465Message CreateAckMessage(HttpStatusCode statusCode, string statusDescription) 467Message ackMessage = new NullMessage(); 561Message message; 562Message responseMessage; 565public ReplyAsyncResult(HttpRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state) 830public override HttpOutput GetHttpOutput(Message message) 958protected override void AddProperties(Message message)
System\ServiceModel\Channels\HttpRequestMessageExtensionMethods.cs (1)
140internal static void CopyPropertiesFromMessage(this HttpRequestMessage httpRequestMessage, Message message)
System\ServiceModel\Channels\HttpRequestMessageProperty.cs (1)
141internal static HttpRequestMessage GetHttpRequestMessageFromMessage(Message message)
System\ServiceModel\Channels\HttpResponseMessageExtensionMethods.cs (1)
80internal static void CopyPropertiesFromMessage(this HttpResponseMessage httpResponseMessage, Message message)
System\ServiceModel\Channels\HttpResponseMessageProperty.cs (1)
166internal static HttpResponseMessage GetHttpResponseMessageFromMessage(Message message)
System\ServiceModel\Channels\ICompressedMessageEncoder.cs (1)
12void AddCompressedMessageProperties(Message message, string supportedCompressionTypes);
System\ServiceModel\Channels\IInputChannel.cs (5)
14Message Receive(); 15Message Receive(TimeSpan timeout); 18Message EndReceive(IAsyncResult result); 20bool TryReceive(TimeSpan timeout, out Message message); 22bool EndTryReceive(IAsyncResult result, out Message message);
System\ServiceModel\Channels\IMessageSource.cs (2)
18Message EndReceive(); 19Message Receive(TimeSpan timeout);
System\ServiceModel\Channels\InputChannel.cs (11)
11class InputChannel : InputQueueChannel<Message>, IInputChannel 56public virtual Message Receive() 61public virtual Message Receive(TimeSpan timeout) 90public Message EndReceive(IAsyncResult result) 95public virtual bool TryReceive(TimeSpan timeout, out Message message) 119public virtual bool EndTryReceive(IAsyncResult result, out Message message) 152internal static Message HelpReceive(IInputChannel channel, TimeSpan timeout) 154Message message; 170internal static Message HelpEndReceive(IAsyncResult result) 180Message message; 198public static Message End(IAsyncResult result)
System\ServiceModel\Channels\InputChannelAcceptor.cs (2)
12class InputChannelAcceptor : SingletonChannelAcceptor<IInputChannel, InputChannel, Message> 24protected override void OnTraceMessageReceived(Message message)
System\ServiceModel\Channels\InternalDuplexChannelFactory.cs (1)
223protected override void OnReceive(Message message)
System\ServiceModel\Channels\InternalDuplexChannelListener.cs (11)
146public Message Receive() 151public Message Receive(TimeSpan timeout) 166public Message EndReceive(IAsyncResult result) 176public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 181public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 186public bool EndTryReceive(IAsyncResult result, out Message message) 232public bool TryReceive(TimeSpan timeout, out Message message) 237public void Send(Message message) 242public void Send(Message message, TimeSpan timeout) 257IOutputChannel ValidateStateAndGetOutputChannel(Message message, TimeoutHelper timeoutHelper) 292public SendAsyncResult(ServerCompositeDuplexChannel outer, Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\IOutputChannel.cs (4)
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);
System\ServiceModel\Channels\IPeerNeighbor.cs (6)
18IAsyncResult BeginSend(Message message, AsyncCallback callback, object state); 19IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state); 21void Send(Message message); 24Message RequestSecurityToken(Message request); 25void Ping(Message request);
System\ServiceModel\Channels\IReliableChannelBinder.cs (13)
35IAsyncResult BeginSend(Message message, TimeSpan timeout, MaskingMode maskingMode, AsyncCallback callback, object state); 36IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state); 38void Send(Message message, TimeSpan timeout); 39void Send(Message message, TimeSpan timeout, MaskingMode maskingMode); 61IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state); 62IAsyncResult BeginRequest(Message message, TimeSpan timeout, MaskingMode maskingMode, AsyncCallback callback, object state); 63Message EndRequest(IAsyncResult result); 64Message Request(Message message, TimeSpan timeout); 65Message Request(Message message, TimeSpan timeout, MaskingMode maskingMode); 71bool AddressResponse(Message request, Message response);
System\ServiceModel\Channels\IRequestChannel.cs (7)
14Message Request(Message message); 15Message Request(Message message, TimeSpan timeout); 16IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state); 17IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state); 18Message EndRequest(IAsyncResult result);
System\ServiceModel\Channels\IRequestReplyCorrelator.cs (2)
12void Add<T>(Message request, T state); 15T Find<T>(Message reply, bool remove);
System\ServiceModel\Channels\IStreamedMessageEncoder.cs (1)
11Stream GetResponseMessageStream(Message message);
System\ServiceModel\Channels\LayeredChannelFactory.cs (14)
92void InternalOnReceive(Message message) 100protected virtual void OnReceive(Message message) 104public Message Receive() 106Message message = InnerChannel.Receive(); 111public Message Receive(TimeSpan timeout) 113Message message = InnerChannel.Receive(timeout); 128public Message EndReceive(IAsyncResult result) 130Message message = InnerChannel.EndReceive(result); 140public bool EndTryReceive(IAsyncResult result, out Message message) 147public bool TryReceive(TimeSpan timeout, out Message message) 246public void Send(Message message) 251public void Send(Message message, TimeSpan timeout) 256public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 261public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\Message.cs (23)
155static public Message CreateMessage(MessageVersion version, string action, object body) 160static public Message CreateMessage(MessageVersion version, string action, object body, XmlObjectSerializer serializer) 169static public Message CreateMessage(MessageVersion version, string action, XmlReader body) 174static public Message CreateMessage(MessageVersion version, string action, XmlDictionaryReader body) 184static public Message CreateMessage(MessageVersion version, string action, BodyWriter body) 193static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader, BodyWriter body) 202static public Message CreateMessage(MessageVersion version, string action) 209static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader) 216static public Message CreateMessage(XmlReader envelopeReader, int maxSizeOfHeaders, MessageVersion version) 221static public Message CreateMessage(XmlDictionaryReader envelopeReader, int maxSizeOfHeaders, MessageVersion version) 227Message message = new StreamedMessage(envelopeReader, maxSizeOfHeaders, version); 231static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, string action) 243static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, object detail, string action) 255static public Message CreateMessage(MessageVersion version, MessageFault fault, string action) 370internal void InitializeReply(Message request) 584Message.ReadFromBodyContentsToEnd(reader, this.Version.Envelope); 621Message.ReadFromBodyContentsToEnd(reader, envelopeVersion); 801Message message; 804public OnWriteBodyContentsAsyncResult(XmlDictionaryWriter writer, Message message, AsyncCallback callback, object state) 823Message message; 826public OnWriteMessageAsyncResult(XmlDictionaryWriter writer, Message message, AsyncCallback callback, object state) 934this.isFault = Message.IsFaultStartElement(reader, version); 1257return Message.ReadStartBody(reader, this.Version.Envelope, out this.isFault, out this.isEmpty);
System\ServiceModel\Channels\MessageBuffer.cs (8)
29Message message = CreateMessage(); 45public abstract Message CreateMessage(); 87public DefaultMessageBuffer(Message message, XmlBuffer msgBuffer) 134public override Message CreateMessage() 139Message msg; 146msg = Message.CreateMessage(msgBuffer.GetReader(0), int.MaxValue, this.version); 252public override Message CreateMessage() 309public override Message CreateMessage()
System\ServiceModel\Channels\MessageEncoder.cs (13)
36public Message ReadMessage(Stream stream, int maxSizeOfHeaders) 41public abstract Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType); 43public Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager) 45Message message = ReadMessage(buffer, bufferManager, null); 49public abstract Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType); 87internal virtual Message ReadMessage(Stream stream, BufferManager bufferManager, int maxBufferSize, string contentType) 97public abstract void WriteMessage(Message message, Stream stream); 99public virtual IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state) 109public ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager) 115public abstract ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, 205internal void ThrowIfMismatchedMessageVersion(Message message) 228Message message; 231public WriteMessageAsyncResult(Message message, Stream stream, MessageEncoder encoder, AsyncCallback callback, object state)
System\ServiceModel\Channels\MessageFault.cs (1)
63public static MessageFault CreateFault(Message message, int maxBufferSize)
System\ServiceModel\Channels\MessageHeaders.cs (2)
477public void CopyHeaderFrom(Message message, int headerIndex) 524public void CopyHeadersFrom(Message message)
System\ServiceModel\Channels\MsmqDecodeHelper.cs (8)
61internal static Message DecodeTransportDatagram(MsmqInputChannelListener listener, MsmqReceiveHelper receiver, MsmqInputMessage msmqMessage, MsmqMessageProperty messageProperty) 126Message message = null; 245Message message = DecodeSessiongramMessage(listener, channel, encoder, messageProperty, incoming, offset, sessionDecoder.EnvelopeSize); 312static Message DecodeSessiongramMessage( 340Message message = null; 356internal static Message DecodeIntegrationDatagram(MsmqIntegrationChannelListener listener, MsmqReceiveHelper receiver, MsmqIntegrationInputMessage msmqMessage, MsmqMessageProperty messageProperty) 360Message message = Message.CreateMessage(MessageVersion.None, (string)null);
System\ServiceModel\Channels\MsmqDiagnostics.cs (4)
111public static void TransferFromTransport(Message message) 210static void DatagramSentOrReceived(NativeMsmqMessage.BufferProperty messageId, Message message, int traceCode, string traceDescription) 234public static void DatagramReceived(NativeMsmqMessage.BufferProperty messageId, Message message) 239public static void DatagramSent(NativeMsmqMessage.BufferProperty messageId, Message message)
System\ServiceModel\Channels\MsmqInputChannel.cs (1)
14protected override Message DecodeMsmqMessage(MsmqInputMessage msmqMessage, MsmqMessageProperty messageProperty)
System\ServiceModel\Channels\MsmqInputChannelBase.cs (6)
111abstract protected Message DecodeMsmqMessage(MsmqInputMessage msmqMessage, MsmqMessageProperty property); 119public Message Receive() 124public Message Receive(TimeSpan timeout) 142public Message EndReceive(IAsyncResult result) 148public bool TryReceive(TimeSpan timeout, out Message message) 217public bool EndTryReceive(IAsyncResult result, out Message message)
System\ServiceModel\Channels\MsmqInputSessionChannel.cs (8)
90public override Message Receive() 95public override Message Receive(TimeSpan timeout) 110public override bool TryReceive(TimeSpan timeout, out Message message) 141return new CompletedAsyncResult<bool, Message>(true, null, callback, state); 151public override bool EndTryReceive(IAsyncResult result, out Message message) 153CompletedAsyncResult<bool, Message> completedResult = result as CompletedAsyncResult<bool, Message>; 157return CompletedAsyncResult<bool, Message>.End(result, out message);
System\ServiceModel\Channels\MsmqMessageProperty.cs (1)
73public static MsmqMessageProperty Get(Message message)
System\ServiceModel\Channels\MsmqOutputChannel.cs (2)
129protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 140protected override void OnSend(Message message, TimeSpan timeout)
System\ServiceModel\Channels\MsmqOutputSessionChannel.cs (3)
188protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 199protected override void OnSend(Message message, TimeSpan timeout) 247ArraySegment<byte> EncodeMessage(Message message)
System\ServiceModel\Channels\MtomMessageEncoder.cs (16)
223public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 242Message message = new BufferedMessage(messageData, messageState); 258public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 272Message message = Message.CreateMessage(reader, maxSizeOfHeaders, version); 285public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 305internal ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset, string boundary) 310ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset, string startInfo, string boundary, string startUri, bool writeMessageHeaders) 363public override void WriteMessage(Message message, Stream stream) 368internal void WriteMessage(Message message, Stream stream, string boundary) 373public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state) 378internal IAsyncResult BeginWriteMessage(Message message, Stream stream, string boundary, AsyncCallback callback, object state) 388void WriteMessage(Message message, Stream stream, string startInfo, string boundary, string startUri, bool writeMessageHeaders) 740Message message; 744public WriteMessageAsyncResult(Message message, Stream stream, MtomMessageEncoder encoder, AsyncCallback callback, object state) 756public WriteMessageAsyncResult(Message message, Stream stream, string boundary, MtomMessageEncoder encoder, AsyncCallback callback, object state)
System\ServiceModel\Channels\OneWayChannelFactory.cs (18)
21public static void AddHeadersTo(Message message, MessageHeader header) 34public static void ValidateMessage(Message message) 43public static bool TryValidateMessage(Message message) 169protected override void AddHeadersTo(Message message) 179protected override void OnSend(Message message, TimeSpan timeout) 181Message response = this.innerChannel.Request(message, timeout); 188protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 195Message response = this.innerChannel.EndRequest(result); 202void ValidateResponse(Message response) 308protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 339protected override void OnSend(Message message, TimeSpan timeout) 345void StampMessage(Message message) 508protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 518protected override void OnSend(Message message, TimeSpan timeout) 567Message message = channel.EndReceive(result); 599void StampInitialMessage(Message message) 656Message message; 663public SendAsyncResult(DuplexSessionOutputChannel parent, Message message, TimeSpan timeout,
System\ServiceModel\Channels\OneWayChannelListener.cs (22)
96Message ProcessContext(RequestContext context, TimeSpan timeout) 104Message result = null; 151public Message Receive() 156public Message Receive(TimeSpan timeout) 173public Message EndReceive(IAsyncResult result) 178public bool TryReceive(TimeSpan timeout, out Message message) 199public bool EndTryReceive(IAsyncResult result, out Message message) 229public static bool End(IAsyncResult result, out Message message) 257public static Message End(IAsyncResult result) 278Message message; 311protected Message Message 584public Message EndReceive(IAsyncResult result) 586Message message = this.InnerChannel.EndReceive(result); 590public bool EndTryReceive(IAsyncResult result, out Message message) 602public Message Receive() 607public Message Receive(TimeSpan timeout) 609Message result = this.InnerChannel.Receive(timeout); 613public bool TryReceive(TimeSpan timeout, out Message message) 625Message ValidateMessage(Message message) 1315bool EnqueueMessage(Message message) 1353Message message = null;
System\ServiceModel\Channels\OpaqueContent.cs (2)
17Message message; 20public OpaqueContent(MessageEncoder encoder, Message message, string mtomBoundary)
System\ServiceModel\Channels\OutputChannel.cs (9)
22public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 27public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 63protected abstract void OnSend(Message message, TimeSpan timeout); 65protected abstract IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state); 69public void Send(Message message) 74public void Send(Message message, TimeSpan timeout) 90protected virtual TraceRecord CreateSendTrace(Message message) 95void EmitTrace(Message message) 105protected virtual void AddHeadersTo(Message message)
System\ServiceModel\Channels\PeerConnector.cs (4)
136void SendMessageToNeighbor(IPeerNeighbor neighbor, Message message, PeerMessageHelpers.CleanupCallback cleanupCallback) 569Message message = ConnectInfoMessageConverter.ToMessage(connectInfo, MessageVersion.Soap12WSAddressing10); 591Message message; 620Message message = WelcomeInfoMessageConverter.ToMessage(welcomeInfo, MessageVersion.Soap12WSAddressing10);
System\ServiceModel\Channels\PeerDuplexChannel.cs (4)
68protected override void AddHeadersTo(Message message) 171protected override void OnEnqueueItem(Message message) 195protected override void OnSend(Message message, TimeSpan timeout) 200protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\PeerDuplexChannelListener.cs (2)
13sealed class PeerDuplexChannelAcceptor : SingletonChannelAcceptor<IDuplexChannel, PeerDuplexChannel, Message> 64protected override void OnTraceMessageReceived(Message message)
System\ServiceModel\Channels\PeerFlooder.cs (12)
37abstract class PeerFlooderBase<TFloodContract, TLinkContract> : IFlooderForThrottle, IPeerFlooderContract<TFloodContract, TLinkContract> where TFloodContract : Message 195protected IAsyncResult BeginSendHelper(IPeerNeighbor neighbor, TimeSpan timeout, Message message, FloodAsyncResult fresult) 265Message fmessage = messageBuffer.CreateMessage(); 312int UpdateHopCount(Message message, out MessageHeader hopHeader, out ulong currentValue) 351Message message = null; 388using (Message filterMessage = messageBuffer.CreateMessage()) 557class PeerFlooderSimple : PeerFlooderBase<Message, UtilityInfo> 569public override bool ShouldProcess(Message message) 573public bool IsNotSeenBefore(Message message, out byte[] id, out int cacheHit) 619public override IAsyncResult OnFloodedMessage(IPeerNeighbor neighbor, Message floodInfo, AsyncCallback callback, object state) 953Message message = (Message)result.AsyncState;
System\ServiceModel\Channels\PeerHelpers.cs (2)
780public static void TurnOffSecurityHeader(Message message) 789public string SelectOperation(ref Message message)
System\ServiceModel\Channels\PeerInputChannel.cs (1)
151protected override void OnEnqueueItem(Message message)
System\ServiceModel\Channels\PeerInputChannelListener.cs (2)
12sealed class PeerInputChannelAcceptor : SingletonChannelAcceptor<IInputChannel, PeerInputChannel, Message> 36protected override void OnTraceMessageReceived(Message message)
System\ServiceModel\Channels\PeerMessageDispatcher.cs (7)
14where TChannel : InputQueueChannel<Message> 18SingletonChannelAcceptor<ChannelInterfaceType, TChannel, Message> singletonChannelAcceptor; 19InputQueueChannel<Message> inputQueueChannel; 21public PeerMessageQueueAdapter(SingletonChannelAcceptor<ChannelInterfaceType, TChannel, Message> singletonChannelAcceptor) 26public PeerMessageQueueAdapter(InputQueueChannel<Message> inputQueueChannel) 31public void EnqueueAndDispatch(Message message, Action callback) 145public void OnMessageAvailable(Message message)
System\ServiceModel\Channels\PeerNeighborManager.cs (8)
307Message message = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, PeerStrings.PingAction); 1080public IAsyncResult BeginSend(Message message, 1086public IAsyncResult BeginSend(Message message, 1092public void Send(Message message) 1129public Message RequestSecurityToken(Message request) 1134public void Ping(Message request)
System\ServiceModel\Channels\PeerNodeImplementation.cs (18)
26public delegate void MessageAvailableCallback(Message message); 344public Guid ProcessOutgoingMessage(Message message, Uri via) 365public void SecureOutgoingMessage(ref Message message, Uri via, TimeSpan timeout, SecurityProtocol securityProtocol) 373public IAsyncResult BeginSend(object registrant, Message message, Uri via, 381Message securedMessage = null; 418using (Message filterMessage = messageBuffer.CreateMessage()) 452using (Message msg = messageBuffer.CreateMessage()) 874bool IPeerNodeMessageHandling.ValidateIncomingMessage(ref Message message, Uri via) 918using (Message message = messageBuffer.CreateMessage()) 932using (Message traceMessage = messageBuffer.CreateMessage()) 940PeerMessagePropagation IPeerNodeMessageHandling.DetermineMessagePropagation(Message message, PeerMessageOrigination origination) 1353services.Add(typeof(IPeerFlooderContract<Message, UtilityInfo>), flooder); 1415Message message = null; 1472Message localCopy; 1881bool IPeerNodeMessageHandling.IsNotSeenBefore(Message message, out byte[] id, out int cacheMiss) 1902PeerMessagePropagation DetermineMessagePropagation(Message message, PeerMessageOrigination origination); 1904bool ValidateIncomingMessage(ref Message data, Uri via); 1906bool IsNotSeenBefore(Message message, out byte[] id, out int cacheMiss);
System\ServiceModel\Channels\PeerOutputChannel.cs (3)
137protected override void OnSend(Message message, TimeSpan timeout) 142protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 164protected override void AddHeadersTo(Message message)
System\ServiceModel\Channels\PeerSecurityHelpers.cs (14)
117public static bool AuthenticateRequest(Claim claim, string password, Message message) 123public static bool AuthenticateResponse(Claim claim, string password, Message message) 150public override void SecureOutgoingMessage(ref Message message, TimeSpan timeout) 153public override void VerifyIncomingMessage(ref Message request, TimeSpan timeout) 523public static PeerHashToken CreateHashTokenFrom(Message message) 614public static PeerHashToken CreateHashTokenFrom(Message message) 759Message reply = null; 767Message request = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, TrustFeb2005Strings.RequestSecurityToken, new PeerRequestSecurityToken(token)); 813public Message ProcessRst(Message message, Claim claim) 817Message reply = null; 842reply = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, TrustFeb2005Strings.RequestSecurityTokenResponse, response); 855public void ProcessRstr(IPeerNeighbor neighbor, Message message, Claim claim)
System\ServiceModel\Channels\PeerSecurityManager.cs (2)
628public Message ProcessRequest(IPeerNeighbor neighbor, Message request)
System\ServiceModel\Channels\PeerService.cs (9)
51IPeerFlooderContract<Message, UtilityInfo> flooder; 78services.TryGetValue(typeof(IPeerFlooderContract<Message, UtilityInfo>), out reply); 79flooder = reply as IPeerFlooderContract<Message, UtilityInfo>; 295IAsyncResult IPeerServiceContract.BeginFloodMessage(Message floodedInfo, AsyncCallback callback, object state) 320Message IPeerServiceContract.ProcessRequestSecurityToken(Message message) 325Message reply = this.config.SecurityManager.ProcessRequest(neighbor, message); 335void IPeerServiceContract.Fault(Message message) 343void IPeerServiceContract.Ping(Message message)
System\ServiceModel\Channels\PeerServiceMessageContracts.cs (5)
151IAsyncResult BeginFloodMessage(Message floodedInfo, AsyncCallback callback, object state); 160Message ProcessRequestSecurityToken(Message message); 163void Ping(Message message); 166void Fault(Message message);
System\ServiceModel\Channels\ReceiveContext.cs (1)
43public static bool TryGet(Message message, out ReceiveContext property)
System\ServiceModel\Channels\ReliableChannelBinder.cs (25)
198protected virtual void AddOutputHeaders(Message message) 263public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, 269public IAsyncResult BeginSend(Message message, TimeSpan timeout, MaskingMode maskingMode, 674protected virtual IAsyncResult OnBeginSend(TChannel channel, Message message, 793protected virtual void OnSend(TChannel channel, Message message, TimeSpan timeout) 851public void Send(Message message, TimeSpan timeout) 856public void Send(Message message, TimeSpan timeout, MaskingMode maskingMode) 1064protected bool ValidateOutputOperation(Message message, TimeSpan timeout, MaskingMode maskingMode) 1085protected RequestContext WrapMessage(Message message) 1128public BinderRequestContext(ReliableChannelBinder<TChannel> binder, Message message) 3210public MessageRequestContext(ReliableChannelBinder<TChannel> binder, Message message) 3223protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 3233protected override void OnReply(Message message, TimeSpan timeout) 3246public ReplyAsyncResult(MessageRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state) 3308Message message; 3329Message message, TimeSpan timeout, MaskingMode maskingMode, AsyncCallback callback, 3467public void Start(Message message, TimeSpan timeout, MaskingMode maskingMode) 3522RequestContext innerContext, Message message) 3543protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, 3624protected override void OnReply(Message message, TimeSpan timeout) 3659TChannel channel, Message message, TimeSpan timeout, MaskingMode maskingMode, 3758Message message = null; 4178CloseInputSessionChannelAsyncResult<IDuplexSessionChannel, Message> 4206protected override void DisposeItem(Message item) 4216protected override bool EndTryInput(IAsyncResult result, out Message item)
System\ServiceModel\Channels\ReliableChannelListener.cs (29)
994Message faultReply; 1064protected abstract Message GetMessage(TItem item); 1068Message message = null; 1239protected abstract void SendReply(Message reply, TInnerChannel channel, TItem item); 1284ReliableListenerOverDatagram<TChannel, TReliableChannel, IDuplexChannel, Message> 1299protected override void DisposeItem(Message item) 1304protected override void EndTryReceiveItem(IDuplexChannel channel, IAsyncResult result, out Message item) 1309protected override Message GetMessage(Message item) 1314protected override void SendReply(Message reply, IDuplexChannel channel, Message item) 1348protected override Message GetMessage(RequestContext item) 1353protected override void SendReply(Message reply, IReplyChannel channel, RequestContext item) 1424protected abstract Message GetMessage(TItem item); 1442Message faultReply = null; 1572protected abstract void SendReply(Message reply, TInnerChannel channel, TItem item); 1576: ReliableListenerOverSession<TChannel, TReliableChannel, IDuplexSessionChannel, IDuplexSession, Message> 1591protected override void DisposeItem(Message item) 1596protected override void EndTryReceiveItem(IDuplexSessionChannel channel, IAsyncResult result, out Message item) 1601protected override Message GetMessage(Message item) 1606protected override void SendReply(Message reply, IDuplexSessionChannel channel, Message item) 1640protected override Message GetMessage(RequestContext item) 1645protected override void SendReply(Message reply, IReplySessionChannel channel, RequestContext item) 1673protected override void ProcessSequencedItem(ServerReliableDuplexSessionChannel channel, Message message, WsrmMessageInfo info) 1699protected override void ProcessSequencedItem(ReliableInputSessionChannelOverDuplex channel, Message message, WsrmMessageInfo info) 1725protected override void ProcessSequencedItem(IDuplexSessionChannel channel, Message message, ServerReliableDuplexSessionChannel reliableChannel, WsrmMessageInfo info, bool newChannel) 1764protected override void ProcessSequencedItem(IDuplexSessionChannel channel, Message message, ReliableInputSessionChannelOverDuplex reliableChannel, WsrmMessageInfo info, bool newChannel)
System\ServiceModel\Channels\ReliableDuplexSessionChannel.cs (19)
23DeliveryStrategy<Message> deliveryStrategy; 90void AddPendingAcknowledgements(Message message) 146Message CreateAcknowledgmentMessage() 153Message message = WsrmUtilities.CreateAcknowledgmentMessage(this.Settings.MessageVersion, 345Message message = null; 736using (Message message = CreateAcknowledgmentMessage()) 865protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 943this.session.OnLocalFault(exception, (Message)null, null); 1109protected override void OnSend(Message message, TimeSpan timeout) 1164using (Message message = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion, 1232this.ReliableSession.OnLocalFault(e, (Message)null, null); 1237Message message = context.RequestMessage; 1278this.deliveryStrategy = new OrderedDeliveryStrategy<Message>(this, this.settings.MaxTransferWindowSize, false); 1280this.deliveryStrategy = new UnorderedDeliveryStrategy<Message>(this, this.settings.MaxTransferWindowSize); 1333Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion, 1360Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion, 1643using (Message message = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion, 1686Message message = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion, 1904Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Settings.MessageVersion,
System\ServiceModel\Channels\ReliableInputSessionChannel.cs (16)
18DeliveryStrategy<Message> deliveryStrategy; 40this.deliveryStrategy = new OrderedDeliveryStrategy<Message>(this, listener.MaxTransferWindowSize, false); 42this.deliveryStrategy = new UnorderedDeliveryStrategy<Message>(this, listener.MaxTransferWindowSize); 80protected DeliveryStrategy<Message> DeliveryStrategy 169protected void AddAcknowledgementHeader(Message message) 210protected Message CreateAcknowledgmentMessage() 220Message message = WsrmUtilities.CreateAcknowledgmentMessage( 319this.session.OnLocalFault(exception, (Message)null, null); 487this.ReliableSession.OnLocalFault(e, (Message)null, null); 492Message message = context.RequestMessage; 523using (Message message = CreateAcknowledgmentMessage()) 595Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Listener.MessageVersion, 617Message message = null; 946this.ReliableSession.OnLocalFault(e, (Message)null, null); 1007Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Listener.MessageVersion, 1034Message message = null;
System\ServiceModel\Channels\ReliableMessagingHelpers.cs (87)
652public static bool AddressReply(Message message, Message faultMessage) 683public abstract void SendFaultAsync(IReliableChannelBinder binder, RequestContext requestContext, Message faultMessage); 837protected abstract TState GetState(RequestContext requestContext, Message faultMessage); 941public override void SendFaultAsync(IReliableChannelBinder binder, RequestContext requestContext, Message faultMessage) 1029Message faultMessage; 1032public FaultState(RequestContext requestContext, Message faultMessage) 1038public Message FaultMessage { get { return this.faultMessage; } } 1071protected override FaultState GetState(RequestContext requestContext, Message faultMessage) 1078class SendFaultHelper : TypedFaultHelper<Message> 1085protected override void AbortState(Message message, bool isOnAbortThread) 1094protected override IAsyncResult BeginSendFault(IReliableChannelBinder binder, Message message, 1100protected override void EndSendFault(IReliableChannelBinder binder, Message message, IAsyncResult result) 1106protected override Message GetState(RequestContext requestContext, Message faultMessage) 1476Message CreateRequestMessage() 1478Message request = Message.CreateMessage(this.messageVersion, this.messageAction, this.messageBody); 1579protected abstract Message OnRequest(Message request, TimeSpan timeout, bool last); 1580protected abstract IAsyncResult OnBeginRequest(Message request, TimeSpan timeout, 1582protected abstract Message OnEndRequest(bool last, IAsyncResult result); 1584public Message Request(TimeSpan timeout) 1593Message request = null; 1594Message reply = null; 1648public Message EndRequest(IAsyncResult result) 1665bool ValidateReply(Message response) 1684Message request; 1686Message response; 1702public static Message End(IAsyncResult result) 1885Message GetReply(Message reply, bool last) 1907protected override Message OnRequest(Message request, TimeSpan timeout, bool last) 1912protected override IAsyncResult OnBeginRequest(Message request, TimeSpan timeout, AsyncCallback callback, object state) 1917protected override Message OnEndRequest(bool last, IAsyncResult result) 1960protected override Message OnRequest(Message request, TimeSpan timeout, bool last) 1972protected override IAsyncResult OnBeginRequest(Message request, TimeSpan timeout, AsyncCallback callback, object state) 1977protected override Message OnEndRequest(bool last, IAsyncResult result) 1992Message request; 1994Message response; 1997internal SendReceiveAsyncResult(SendReceiveReliableRequestor requestor, Message request, TimeSpan timeout, 2026public static Message End(IAsyncResult result) 2127Message request; 2147Message GetReply(bool last) 2177protected override Message OnRequest(Message request, TimeSpan timeout, bool last) 2186protected override IAsyncResult OnBeginRequest(Message request, TimeSpan timeout, AsyncCallback callback, object state) 2200protected override Message OnEndRequest(bool last, IAsyncResult result) 2287public Message Message 2439Message reply; 2451protected Message Reply 2456public static Message End(IAsyncResult result) 2462public static Message End(IAsyncResult result, out Exception handledException) 3068Message message, UniqueId id, SequenceRangeCollection ranges, bool final) 3074Message message, UniqueId id, SequenceRangeCollection ranges, bool final, int bufferRemaining) 3080internal static void AddAckRequestedHeader(ReliableMessagingVersion reliableMessagingVersion, Message message, 3086internal static void AddSequenceHeader(ReliableMessagingVersion reliableMessagingVersion, Message message, 3101internal static Message CreateAcknowledgmentMessage(MessageVersion version, 3105Message message = Message.CreateMessage(version, 3115internal static Message CreateAckRequestedMessage(MessageVersion messageVersion, 3118Message message = Message.CreateMessage(messageVersion, 3127internal static Message CreateCloseSequenceResponse(MessageVersion messageVersion, UniqueId messageId, 3132Message message = Message.CreateMessage(messageVersion, 3139internal static Message CreateCreateSequenceResponse(MessageVersion messageVersion, 3151Message responseMessage 3152= Message.CreateMessage(messageVersion, ActionHeader.Create( 3158internal static Message CreateCSRefusedCommunicationFault(MessageVersion messageVersion, 3164internal static Message CreateCSRefusedProtocolFault(MessageVersion messageVersion, 3170internal static Message CreateCSRefusedServerTooBusyFault(MessageVersion messageVersion, 3180static Message CreateCSRefusedFault(MessageVersion messageVersion, 3208return Message.CreateMessage(messageVersion, fault, action); 3212ReliableMessagingVersion reliableMessagingVersion, Message message, IChannel innerChannel) 3279internal static Message CreateEndpointNotFoundFault(MessageVersion version, string reason) 3299return Message.CreateMessage(version, fault, version.Addressing.DefaultFaultAction); 3302internal static Message CreateTerminateMessage(MessageVersion version, 3308internal static Message CreateTerminateMessage(MessageVersion version, 3311Message message = Message.CreateMessage(version, 3320internal static Message CreateTerminateResponseMessage(MessageVersion version, UniqueId messageId, UniqueId sequenceId) 3322Message message = Message.CreateMessage(version, 3523Message faultReply;
System\ServiceModel\Channels\ReliableOutputConnection.cs (8)
156Message message = Message.CreateMessage(this.MessageVersion, WsrmFeb2005Strings.LastMessageAction); 179public bool AddMessage(Message message, TimeSpan timeout, object state) 184public IAsyncResult BeginAddMessage(Message message, TimeSpan timeout, object state, AsyncCallback callback, object asyncState) 198Message message = Message.CreateMessage(this.MessageVersion, WsrmFeb2005Strings.LastMessageAction); 360bool InternalAddMessage(Message message, TimeSpan timeout, object state, bool isLast) 628public AddAsyncResult(Message message, bool isLast, TimeSpan timeout, object state,
System\ServiceModel\Channels\ReliableOutputSessionChannel.cs (30)
114Message closeReply = this.closeRequestor.Request(timeout); 126Message closeReply = this.closeRequestor.EndRequest(result); 255protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 286this.session.OnLocalFault(exception, (Message)null, null); 311protected abstract void OnConnectionSend(Message message, TimeSpan timeout, bool saveHandledException, 320using (Message message = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion, 330Message request = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion, 390protected abstract void OnConnectionSendMessage(Message message, TimeSpan timeout, MaskingMode maskingMode); 391protected abstract IAsyncResult OnConnectionBeginSendMessage(Message message, TimeSpan timeout, 448protected override void OnSend(Message message, TimeSpan timeout) 472using (Message request = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion, 479void ProcessCloseOrTerminateReply(bool close, Message reply) 522protected void ProcessMessage(Message message) 597Message response = WsrmUtilities.CreateTerminateResponseMessage( 675Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion, 682Message terminateReply = this.terminateRequestor.Request(timeout); 701Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion, 724Message terminateReply = this.terminateRequestor.EndRequest(result); 787protected override void OnConnectionSend(Message message, TimeSpan timeout, 791Message reply = null; 849Message reply = ReliableBinderRequestAsyncResult.End(result, out handledException); 860protected override void OnConnectionSendMessage(Message message, TimeSpan timeout, MaskingMode maskingMode) 862Message reply = this.binder.Request(message, timeout, maskingMode); 870protected override IAsyncResult OnConnectionBeginSendMessage(Message message, TimeSpan timeout, 884Message reply = ReliableBinderRequestAsyncResult.End(result); 924protected override void OnConnectionSend(Message message, TimeSpan timeout, bool saveHandledException, bool maskUnhandledException) 989protected override void OnConnectionSendMessage(Message message, TimeSpan timeout, MaskingMode maskingMode) 994protected override IAsyncResult OnConnectionBeginSendMessage(Message message, TimeSpan timeout, 1063Message requestMessage = context.RequestMessage; 1074this.ReliableSession.OnLocalFault(e, (Message)null, null);
System\ServiceModel\Channels\ReliableReplySessionChannel.cs (30)
164void AddAcknowledgementHeader(Message message) 232Message CreateAcknowledgement(SequenceRangeCollection ranges) 234Message message = WsrmUtilities.CreateAcknowledgmentMessage( 245Message CreateSequenceClosedFault() 247Message message = new SequenceClosedFault(this.session.InputID).CreateMessage( 392this.session.OnLocalFault(e, (Message)null, null); 474this.session.OnLocalFault(exception, (Message)null, null); 484this.session.OnLocalFault(exception, (Message)null, null); 631Message PrepareReplyMessage(Int64 replySequenceNumber, bool isLast, SequenceRangeCollection ranges, Message reply) 690using (Message reply = CreateAcknowledgement(this.connection.Ranges)) 808Message message = WsrmUtilities.CreateTerminateMessage(this.MessageVersion, 920Message response = WsrmUtilities.CreateCreateSequenceResponse(this.listener.MessageVersion, 1043Message message = null; 1180Message message = null; 1402internal IAsyncResult BeginReplyInternal(Message reply, TimeSpan timeout, AsyncCallback callback, object state) 1504this.channel.session.OnLocalFault(e, (Message)null, null); 1508protected override IAsyncResult OnBeginReply(Message reply, TimeSpan timeout, AsyncCallback callback, object state) 1525protected override void OnReply(Message reply, TimeSpan timeout) 1530internal void ReplyInternal(Message reply, TimeSpan timeout) 1594this.bufferedReply = Message.CreateMessage(this.channel.MessageVersion, WsrmFeb2005Strings.LastMessageAction).CreateBufferedCopy(int.MaxValue); 1605Message reply; 1647Message reply; 1744Message asyncMessage; 1796using (Message message = this.replyProvider.Provide(this.channel, info)) 1950internal abstract Message Provide(ReliableReplySessionChannel channel, WsrmMessageInfo info); 1974internal override Message Provide(ReliableReplySessionChannel channel, WsrmMessageInfo requestInfo) 1976Message message = WsrmUtilities.CreateCloseSequenceResponse(channel.MessageVersion, 2004internal override Message Provide(ReliableReplySessionChannel channel, WsrmMessageInfo requestInfo) 2006Message message = WsrmUtilities.CreateTerminateResponseMessage(channel.MessageVersion,
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (24)
66void AddAcknowledgementHeader(Message message, bool force) 91Message closeReply = this.closeRequestor.Request(timeout); 103Message closeReply = this.closeRequestor.EndRequest(result); 117Message CreateAckRequestedMessage() 119Message request = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion, 125protected override IAsyncRequest CreateAsyncRequest(Message message, AsyncCallback callback, object state) 147protected override IRequest CreateRequest(Message message) 177Message terminateReply = this.terminateRequestor.EndRequest(result); 308this.session.OnLocalFault(exception, (Message)null, null); 381Message reply = ReliableBinderRequestAsyncResult.End(result, out handledException); 414Message reply = null; 548void ProcessCloseOrTerminateReply(bool close, Message reply) 610void ProcessReply(Message reply, IReliableRequest request, Int64 requestSequenceNumber) 786Message reply = ReliableBinderRequestAsyncResult.End(result); 797Message terminateReply = this.terminateRequestor.Request(timeout); 880void Set(Message reply); 891Message reply; 942public void SendRequest(Message message, TimeSpan timeout) 949public void Set(Message reply) 970public Message WaitForReply(TimeSpan timeout) 1051Message reply; 1107public void BeginSendRequest(Message message, TimeSpan timeout) 1120public Message End() 1126public void Set(Message reply)
System\ServiceModel\Channels\ReplyAdapterChannelListener.cs (11)
150Message message; 167Message message; 192RequestContext WrapInnerMessage(Message message) 208Message request; 213public DuplexRequestContext(Message request, IDefaultCommunicationTimeouts defaultTimeouts, IDuplexChannel innerChannel) 225public override Message RequestMessage 248public override void Reply(Message message) 253public override void Reply(Message message, TimeSpan timeout) 259public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state) 264public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 275void PrepareReply(Message message)
System\ServiceModel\Channels\RequestChannel.cs (16)
212public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 217public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 249protected abstract IRequest CreateRequest(Message message); 250protected abstract IAsyncRequest CreateAsyncRequest(Message message, AsyncCallback callback, object state); 252public Message EndRequest(IAsyncResult result) 268Message reply = asyncRequest.End(); 284public Message Request(Message message) 289public Message Request(Message message, TimeSpan timeout) 307Message reply; 348protected virtual void AddHeadersTo(Message message) 447void SendRequest(Message message, TimeSpan timeout); 448Message WaitForReply(TimeSpan timeout); 453void BeginSendRequest(Message message, TimeSpan timeout); 454Message End();
System\ServiceModel\Channels\RequestContext.cs (5)
10public abstract Message RequestMessage { get; } 17public abstract void Reply(Message message); 18public abstract void Reply(Message message, TimeSpan timeout); 19public abstract IAsyncResult BeginReply(Message message, AsyncCallback callback, object state); 20public abstract IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state);
System\ServiceModel\Channels\RequestContextBase.cs (11)
18Message requestMessage; 25protected RequestContextBase(Message requestMessage, TimeSpan defaultCloseTimeout, TimeSpan defaultSendTimeout) 32public void ReInitialize(Message requestMessage) 42public override Message RequestMessage 56protected void SetRequestMessage(Message requestMessage) 194protected abstract void OnReply(Message message, TimeSpan timeout); 195protected abstract IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state); 232public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state) 237public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 255public override void Reply(Message message) 260public override void Reply(Message message, TimeSpan timeout)
System\ServiceModel\Channels\RequestReplyCorrelator.cs (12)
23void IRequestReplyCorrelator.Add<T>(Message request, T state) 43T IRequestReplyCorrelator.Find<T>(Message reply, bool remove) 76UniqueId GetRelatesTo(Message reply) 84internal static bool AddressReply(Message reply, Message request) 90internal static bool AddressReply(Message reply, ReplyToInfo info) 125internal static ReplyToInfo ExtractReplyToInfo(Message message) 130internal static void PrepareRequest(Message request) 146internal static void PrepareReply(Message reply, UniqueId messageId) 164internal static void PrepareReply(Message reply, Message request) 190internal ReplyToInfo(Message message)
System\ServiceModel\Channels\SecurityChannelFactory.cs (29)
344protected bool TryGetSecurityFaultException(Message faultMessage, out Exception faultException) 547public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 552public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 564public void Send(Message message) 569public void Send(Message message, TimeSpan timeout) 602public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 607public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 614public Message EndRequest(IAsyncResult result) 619public Message Request(Message message) 624internal Message ProcessReply(Message reply, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 653Message unverifiedMessage = reply; 677public Message Request(Message message, TimeSpan timeout) 683Message reply = this.InnerChannel.Request(message, timeoutHelper.RemainingTime()); 729public Message Receive() 734public Message Receive(TimeSpan timeout) 749public Message EndReceive(IAsyncResult result) 767public virtual bool EndTryReceive(IAsyncResult result, out Message message) 778internal Message ProcessMessage(Message message, TimeSpan timeout) 784Message unverifiedMessage = message; 810public bool TryReceive(TimeSpan timeout, out Message message) 866Message reply; 869public RequestChannelSendAsyncResult(Message message, SecurityProtocol protocol, IRequestChannel channel, SecurityRequestChannel securityChannel, TimeSpan timeout, 877protected override IAsyncResult BeginSendCore(IRequestChannel channel, Message message, TimeSpan timeout, AsyncCallback callback, object state) 882internal static Message End(IAsyncResult result) 910protected override bool OnInnerReceiveDone(ref Message message, TimeSpan timeout)
System\ServiceModel\Channels\SecurityChannelFaultConverter.cs (2)
20protected override bool OnTryCreateException(Message message, MessageFault fault, out Exception exception) 40protected override bool OnTryCreateFaultMessage(Exception exception, out Message message)
System\ServiceModel\Channels\SecurityChannelListener.cs (65)
787void ThrowIfSecureConversationCloseMessage(Message message) 798IDisposable ApplyHostingIntegrationContext(Message message) 812internal SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout, params SecurityProtocolCorrelationState[] correlationState) 828internal void VerifyIncomingMessage(ref Message message, TimeSpan timeout) 906public Message Receive() 911public Message Receive(TimeSpan timeout) 926public Message EndReceive(IAsyncResult result) 941public virtual bool EndTryReceive(IAsyncResult result, out Message message) 952public virtual bool TryReceive(TimeSpan timeout, out Message message) 1046public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 1051public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1063public void Send(Message message) 1068public void Send(Message message, TimeSpan timeout) 1098void SendFaultIfRequired(Exception e, Message unverifiedMessage, TimeSpan timeout) 1111using (Message faultMessage = Message.CreateMessage(unverifiedMessage.Version, fault, unverifiedMessage.Version.Addressing.DefaultFaultAction)) 1129public override bool TryReceive(TimeSpan timeout, out Message message) 1151Message unverifiedMessage = message; 1186public override bool EndTryReceive(IAsyncResult result, out Message message) 1270Message message = requestContext.RequestMessage; 1290Message requestMessage = innerContext.RequestMessage; 1291Message faultMessage = Message.CreateMessage(requestMessage.Version, fault, requestMessage.Version.Addressing.DefaultFaultAction); 1400public SecurityRequestContext(Message requestMessage, RequestContext innerContext, 1420protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1445protected override void OnReply(Message message, TimeSpan timeout) 1457public RequestContextSendAsyncResult(Message message, SecurityProtocol protocol, RequestContext context, TimeSpan timeout, 1464protected override IAsyncResult BeginSendCore(RequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state) 1496Message faultMessage; 1545protected abstract Message CreateFaultMessage(MessageFault fault, TItem innerItem); 1546protected abstract IAsyncResult BeginSendFault(TItem innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state); 1690bool SendFault(Message faultMessage, Exception e) 1843protected override Message CreateFaultMessage(MessageFault fault, RequestContext innerItem) 1845Message requestMessage = innerItem.RequestMessage; 1846Message faultMessage = Message.CreateMessage(requestMessage.Version, fault, requestMessage.Version.Addressing.DefaultFaultAction); 1852protected override IAsyncResult BeginSendFault(RequestContext innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state) 1870sealed class DuplexSessionReceiveMessageAndVerifySecurityAsyncResult : ReceiveItemAndVerifySecurityAsyncResult<Message, IInputChannel> 1902protected override void AbortInnerItem(Message innerItem) 1906protected override void CloseInnerItem(Message innerItem, TimeSpan timeout) 1916protected override bool EndTryReceiveItem(IAsyncResult result, out Message innerItem) 1921protected override Message ProcessInnerItem(Message innerItem, TimeSpan timeout) 1927Message item = innerItem; 1932protected override Message CreateFaultMessage(MessageFault fault, Message innerItem) 1934Message faultMessage = Message.CreateMessage(innerItem.Version, fault, innerItem.Version.Addressing.DefaultFaultAction); 1940protected override IAsyncResult BeginSendFault(Message innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state) 1945protected override void EndSendFault(Message innerItem, IAsyncResult result) 1950public static bool End(IAsyncResult result, out Message message) 1959sealed class InputChannelReceiveMessageAndVerifySecurityAsyncResult : ReceiveItemAndVerifySecurityAsyncResult<Message, IInputChannel> 1996protected override void AbortInnerItem(Message innerItem) 2000protected override void CloseInnerItem(Message innerItem, TimeSpan timeout) 2010protected override bool EndTryReceiveItem(IAsyncResult result, out Message innerItem) 2015protected override Message ProcessInnerItem(Message innerItem, TimeSpan timeout) 2021Message item = innerItem; 2026protected override Message CreateFaultMessage(MessageFault fault, Message innerItem) 2031protected override IAsyncResult BeginSendFault(Message innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state) 2036protected override void EndSendFault(Message innerItem, IAsyncResult result) 2041public static bool End(IAsyncResult result, out Message message)
System\ServiceModel\Channels\ServerReliableChannelBinder.cs (12)
93void AddAddressedProperty(Message message) 98protected override void AddOutputHeaders(Message message) 107public bool AddressResponse(Message request, Message response) 302object GetAddressedProperty(Message message) 698protected override IAsyncResult OnBeginSend(TDuplexChannel channel, Message message, 724Message message; 740protected abstract void OnMessageReceived(Message message); 742protected override void OnSend(TDuplexChannel channel, Message message, 751Message message; 805protected override void OnMessageReceived(Message message) 867protected override void OnMessageReceived(Message message)
System\ServiceModel\Channels\ServiceChannel.cs (16)
932internal void FireUnknownMessageReceived(Message message) 1077void ThrowIfFaultUnderstood(Message reply, MessageFault fault, string action, MessageVersion version, FaultConverter faultConverter) 1244void AddMessageProperties(Message message, OperationContext context) 1273public void Send(Message message) 1278public void Send(Message message, TimeSpan timeout) 1284public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 1289public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1300public Message Request(Message message) 1305public Message Request(Message message, TimeSpan timeout) 1308return (Message)this.Call(message.Headers.Action, false, operation, new object[] { message }, EmptyArray<object>.Instance, timeout); 1311public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 1316public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1322public Message EndRequest(IAsyncResult result) 1324return (Message)this.EndCall(MessageHeaders.WildcardAction, EmptyArray<object>.Instance, result);
System\ServiceModel\Channels\ServiceContextProtocol.cs (5)
21public override void OnIncomingMessage(Message message) 48public override void OnOutgoingMessage(Message message, RequestContext requestContext) 86void OnReceiveHttpCookies(Message message) 104void OnReceiveSoapContextHeader(Message message) 121void OnSendHttpCookies(Message message, ContextMessageProperty context, Uri requestUri)
System\ServiceModel\Channels\SessionConnectionReader.cs (18)
406protected override void PrepareMessage(Message message) 1009protected override Message DecodeMessage(byte[] buffer, ref int offset, ref int size, ref bool isAtEof, TimeSpan timeout) 1054Message message = null; 1085protected override void PrepareMessage(Message message) 1114Message pendingMessage; 1138Message DecodeMessage(TimeSpan timeout) 1158protected abstract Message DecodeMessage(byte[] buffer, ref int offset, ref int size, ref bool isAtEof, TimeSpan timeout); 1278public Message Receive(TimeSpan timeout) 1280Message message = GetPendingMessage(); 1336public Message EndReceive() 1341Message GetPendingMessage() 1352Message message = pendingMessage; 1377Message message = EndReceive(); 1396Message message = Receive(timeout); 1444Message message = DecodeMessage(this.readTimeoutHelper.RemainingTime()); 1486protected virtual void PrepareMessage(Message message) 1560protected override Message DecodeMessage(byte[] buffer, ref int offset, ref int size, ref bool isAtEOF, TimeSpan timeout) 1603Message message = null;
System\ServiceModel\Channels\SingletonConnectionReader.cs (15)
1017protected override void PrepareMessage(Message message) 1166protected virtual void PrepareMessage(Message message) 1174Message requestMessage = Receive(timeout); 1183public virtual Message EndReceive(IAsyncResult result) 1188public Message Receive(TimeSpan timeout) 1241Message message = null; 1268Message message; 1283public static Message End(IAsyncResult result) 1318public StreamedFramingRequestContext(SingletonConnectionReader parent, Message requestMessage) 1336protected override void OnReply(Message message, TimeSpan timeout) 1349protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1610public static void WriteMessage(Message message, IConnection connection, bool isRequest, 1661public static IAsyncResult BeginWriteMessage(Message message, IConnection connection, bool isRequest, 1716Message message; 1727public WriteMessageAsyncResult(Message message, IConnection connection, bool isRequest,
System\ServiceModel\Channels\StreamedFramingRequestChannel.cs (9)
78protected override IAsyncRequest CreateAsyncRequest(Message message, AsyncCallback callback, object state) 83protected override IRequest CreateRequest(Message message) 549public void SendRequest(Message message, TimeSpan timeout) 580public Message WaitForReply(TimeSpan timeout) 586Message message = connectionReader.Receive(timeout); 621Message message; 622Message replyMessage; 636public void BeginSendRequest(Message message, TimeSpan timeout) 690public Message End()
System\ServiceModel\Channels\SynchronizedMessageSource.cs (3)
57public Message EndReceive(IAsyncResult result) 62public Message Receive(TimeSpan timeout) 199class ReceiveAsyncResult : SynchronizedAsyncResult<Message>
System\ServiceModel\Channels\TextMessageEncoder.cs (10)
406public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 416Message message; 442public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 453Message message = Message.CreateMessage(reader, maxSizeOfHeaders, version); 466public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 510public override void WriteMessage(Message message, Stream stream) 549public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state) 570Message message; 575public WriteMessageAsyncResult(Message message, Stream stream, TextMessageEncoder textEncoder, AsyncCallback callback, object state)
System\ServiceModel\Channels\TransactionChannel.cs (12)
23void WriteTransactionDataToMessage(Message message, MessageDirection direction); 24void ReadTransactionDataFromMessage(Message message, MessageDirection direction); 27void ReadIssuedTokens(Message message, MessageDirection direction); 28void WriteIssuedTokens(Message message, MessageDirection direction); 98void FaultOnMessage(Message message, string reason, string codeString) 105ICollection<RequestSecurityTokenResponse> GetIssuedTokens(Message message) 110public void ReadIssuedTokens(Message message, MessageDirection direction) 130void ReadTransactionFromMessage(Message message, TransactionFlowOption txFlowOption) 153public virtual void ReadTransactionDataFromMessage(Message message, MessageDirection direction) 164public void WriteTransactionDataToMessage(Message message, MessageDirection direction) 180void WriteTransactionToMessage(Message message, TransactionFlowOption txFlowOption) 201public void WriteIssuedTokens(Message message, MessageDirection direction)
System\ServiceModel\Channels\TransactionChannelFactory.cs (13)
241public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 246public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state) 259public void Send(Message message) 264public void Send(Message message, TimeSpan timeout) 298public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 303public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state) 310public Message EndRequest(IAsyncResult result) 312Message reply = InnerChannel.EndRequest(result); 318public Message Request(Message message) 323public Message Request(Message message, TimeSpan timeout) 327Message reply = InnerChannel.Request(message, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\TransactionChannelFaultConverter.cs (2)
21protected override bool OnTryCreateException(Message message, MessageFault fault, out Exception exception) 51protected override bool OnTryCreateFaultMessage(Exception exception, out Message message)
System\ServiceModel\Channels\TransactionChannelListener.cs (16)
203protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 238protected override void OnReply(Message message, TimeSpan timeout) 278public Message Receive() 283public Message Receive(TimeSpan timeout) 298public Message EndReceive(IAsyncResult result) 308public virtual bool EndTryReceive(IAsyncResult asyncResult, out Message message) 323public virtual bool TryReceive(TimeSpan timeout, out Message message) 417Message reply = Message.CreateMessage(innerContext.RequestMessage.Version, fault.CreateMessageFault(), faultAction); 535public override void ReadTransactionDataFromMessage(Message message, MessageDirection direction) 543Message reply = Message.CreateMessage(message.Version, fault.CreateMessageFault(), fault.Action); 561public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 566public virtual IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state) 578public void Send(Message message) 583public virtual void Send(Message message, TimeSpan timeout)
System\ServiceModel\Channels\TransactionFlowProperty.cs (11)
45static internal TransactionMessageProperty TryGet(Message message) 53static internal Transaction TryGetTransaction(Message message) 62static TransactionMessageProperty GetPropertyAndThrowIfAlreadySet(Message message) 73static public void Set(Transaction transaction, Message message) 80static internal void Set(TransactionInfo transactionInfo, Message message) 118static internal TransactionFlowProperty Ensure(Message message) 128static internal TransactionFlowProperty TryGet(Message message) 136static internal ICollection<RequestSecurityTokenResponse> TryGetIssuedTokens(Message message) 149static internal Transaction TryGetTransaction(Message message) 158static TransactionFlowProperty GetPropertyAndThrowIfAlreadySet(Message message) 177static internal void Set(Transaction transaction, Message message)
System\ServiceModel\Channels\TransmissionStrategy.cs (15)
17readonly Message message; 22public MessageAttemptInfo(Message message, Int64 sequenceNumber, int retryCount, object state) 29public Message Message 208public bool Add(Message message, TimeSpan timeout, object state, out MessageAttemptInfo attemptInfo) 213public MessageAttemptInfo AddLast(Message message, TimeSpan timeout, object state) 226MessageAttemptInfo AddToWindow(Message message, bool isLast, object state) 256public IAsyncResult BeginAdd(Message message, TimeSpan timeout, object state, AsyncCallback callback, object asyncState) 261public IAsyncResult BeginAddLast(Message message, TimeSpan timeout, object state, AsyncCallback callback, object asyncState) 468bool InternalAdd(Message message, bool isLast, TimeSpan timeout, object state, out MessageAttemptInfo attemptInfo) 500IAsyncResult InternalBeginAdd(Message message, bool isLast, TimeSpan timeout, object state, AsyncCallback callback, object asyncState) 851public AsyncQueueAdder(Message message, bool isLast, TimeSpan timeout, object state, TransmissionStrategy strategy, AsyncCallback callback, object asyncState) 962public void Add(Message message, Int64 addTime, object state) 997public Message GetMessage(int index) 1089public TransmissionInfo(Message message, Int64 lastAttemptTime, object state) 1108public WaitQueueAdder(TransmissionStrategy strategy, Message message, bool isLast, object state)
System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (23)
104public Message Receive() 109public Message Receive(TimeSpan timeout) 111Message message = null; 170public Message EndReceive(IAsyncResult result) 186Message message = null; 214public bool EndTryReceive(IAsyncResult result, out Message message) 219public bool TryReceive(TimeSpan timeout, out Message message) 438protected virtual void OnReceiveMessage(Message message) 450protected void ApplyChannelBinding(Message message) 455protected virtual void PrepareMessage(Message message) 493protected abstract AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, WaitCallback callback, object state); 501protected abstract ArraySegment<byte> EncodeMessage(Message message); 503protected abstract void OnSendCore(Message message, TimeSpan timeout); 505protected abstract AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, WaitCallback callback, object state); 507protected override void OnSend(Message message, TimeSpan timeout) 552protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 577Message message = this.MessageSource.Receive(timeout); 837Message message = this.channel.messageSource.EndReceive(result); 1037Message message; 1043public SendAsyncResult(TransportDuplexSessionChannel channel, Message message, TimeSpan timeout, bool streamedOutput, AsyncCallback callback, object state) 1159Message message = this.message; 1229Message message; 1264public static bool End(IAsyncResult result, out Message message)
System\ServiceModel\Channels\TransportOutputChannel.cs (1)
103protected override void AddHeadersTo(Message message)
System\ServiceModel\Channels\UtilityExtension.cs (4)
256public Message message; 258public AsyncUtilityState(Message message, UtilityInfo info) 272Message message = MessageConverter.ToMessage(umessage, MessageVersion.Soap12WSAddressing10); 315Message message = state.message;
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (16)
204protected override AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Threading.WaitCallback callback, object state) 259protected override AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, WaitCallback callback, object state) 314protected override void OnSendCore(Message message, TimeSpan timeout) 371protected override ArraySegment<byte> EncodeMessage(Message message) 447static WebSocketMessageType GetWebSocketMessageType(Message message) 492Message pendingMessage; 590public Message EndReceive() 602Message message = this.GetPendingMessage(); 614public Message Receive(TimeSpan timeout) 626Message message = this.GetPendingMessage(); 763Message message = this.EndReceive(); 784Message message = this.Receive(timeout); 949Message GetPendingMessage() 955Message pendingMessage = this.pendingMessage; 963Message PrepareMessage(WebSocketReceiveResult result, byte[] buffer, int count) 967Message 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 (21)
26Message faultReply; 27Message message; 120public Message FaultReply 137public Message Message 209public static Exception CreateInternalFaultException(Message faultReply, string message, Exception inner) 218Message faultReply = new WsrmRequiredFault(faultReason).CreateMessage(messageVersion, 226ReliableMessagingVersion reliableMessagingVersion, IChannel channel, ISession session, Message message) 232ReliableMessagingVersion reliableMessagingVersion, IChannel channel, ISession session, Message message, 667static void ValidateMustUnderstand(MessageVersion version, Message message) 680Message faultReply; 687public InternalFaultException(Message faultReply, string message, Exception inner) 698public Message FaultReply 745public static CloseSequenceInfo ReadMessage(MessageVersion messageVersion, Message message, 797public static CloseSequenceResponseInfo ReadMessage(MessageVersion messageVersion, Message message, 901Message message, MessageHeaders headers) 907Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 924Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 955Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, 1005ReliableMessagingVersion reliableMessagingVersion, Message message, MessageHeaders headers) 1072ReliableMessagingVersion reliableMessagingVersion, Message message, MessageHeaders headers) 1127public static TerminateSequenceResponseInfo ReadMessage(MessageVersion messageVersion, Message message,
System\ServiceModel\ClientBase.cs (11)
1363void IOutputChannel.Send(Message message) 1368void IOutputChannel.Send(Message message, TimeSpan timeout) 1373IAsyncResult IOutputChannel.BeginSend(Message message, AsyncCallback callback, object state) 1378IAsyncResult IOutputChannel.BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1398Message IRequestChannel.Request(Message message) 1403Message IRequestChannel.Request(Message message, TimeSpan timeout) 1408IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state) 1413IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1418Message IRequestChannel.EndRequest(IAsyncResult result)
System\ServiceModel\ComIntegration\ComPlusDiagnosticTraceRecords.cs (2)
135public static void Trace(TraceEventType type, int traceCode, string description, ServiceInfo info, Message message, Guid incomingTransactionID) 149public static void Trace(TraceEventType type, int traceCode, string description, ServiceInfo info, Message message, int instanceID, Guid incomingTransactionID)
System\ServiceModel\ComIntegration\ComPlusInstanceContextInitializer.cs (2)
63public void Initialize(InstanceContext instanceContext, Message message) 111object SetupServiceConfig(InstanceContext instanceContext, Message message)
System\ServiceModel\ComIntegration\ComPlusInstanceProvider.cs (1)
40public object GetInstance(InstanceContext instanceContext, Message message)
System\ServiceModel\ComIntegration\ComPlusThreadInitializer.cs (1)
78Message message)
System\ServiceModel\ComIntegration\MessageUtil.cs (2)
21public static WindowsIdentity GetMessageIdentity(Message message) 55public static Transaction GetMessageTransaction(Message message)
System\ServiceModel\Description\IMetadataExchange.cs (4)
13Message Get(Message request); 16IAsyncResult BeginGet(Message request, AsyncCallback callback, object state); 17Message EndGet(IAsyncResult result);
System\ServiceModel\Description\MessageContractImporter.cs (1)
655return CheckAndAddPart(part.Type, DataContractSerializerMessageContractImporter.GenericMessageTypeName, part.Name, string.Empty, typeof(Message), description, isReply);
System\ServiceModel\Description\MessageDescription.cs (1)
129typeOfUntypedMessage = typeof(Message);
System\ServiceModel\Description\MetadataExchangeClient.cs (6)
1037static Message CreateGetMessage(MessageVersion messageVersion) 1039return Message.CreateMessage(messageVersion, MetadataStrings.WSTransfer.GetAction); 1066Message response; 1072using (Message getMessage = CreateGetMessage(messageVersion)) 1127Message message; 1173Message response = metadataClient.EndGet(result);
System\ServiceModel\Description\OperationGenerator.cs (2)
382this.Method.Parameters.Insert(0, new CodeParameterDeclarationExpression(Context.ServiceContractGenerator.GetCodeTypeReference((typeof(Message))), "request")); 384this.EndMethod.ReturnType = Context.ServiceContractGenerator.GetCodeTypeReference(typeof(Message));
System\ServiceModel\Description\ServiceMetadataExtension.cs (28)
195internal static bool TryGetHttpHostAndPort(Uri listenUri, Message request, out string host, out int port) 465WriteFilter GetWriteFilter(Message request, Uri listenUri, bool removeBaseAddress) 488DynamicAddressUpdateWriter GetDynamicAddressWriter(Message request, Uri listenUri, bool removeBaseAddress) 601public Message Get(Message request) 614public IAsyncResult BeginGet(Message request, AsyncCallback callback, object state) 619public Message EndGet(IAsyncResult result) 630Message Get(Message msg); 719bool TryHandleDocumentationRequest(Message httpGetRequest, string[] queries, out Message replyMessage) 816bool TryHandleHealthRequest(Message httpGetRequest, string[] queries, out Message replyMessage) 837bool TryHandleMetadataRequest(Message httpGetRequest, string[] queries, out Message replyMessage) 955Message CreateDiscoMessage(DynamicAddressUpdateWriter addressUpdater) 1007Message ProcessHttpRequest(Message httpGetRequest) 1019Message replyMessage = null; 1033public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext) 1038public void BeforeSendReply(ref Message reply, object correlationState) 1060public Message Get(Message message) 1288static void AddHttpProperty(Message message, HttpStatusCode status, string contentType) 1296static Message CreateRedirectMessage(string redirectedDestination) 1298Message redirectMessage = CreateHttpResponseMessage(HttpStatusCode.RedirectKeepVerb); 1304static Message CreateHttpResponseMessage(HttpStatusCode code) 1306Message message = new NullMessage();
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)
35internal static Guid ExtractActivityId(Message message) 71internal static bool ExtractActivityAndCorrelationId(Message message, out Guid activityId, out Guid correlationId) 114internal void AddTo(Message message)
System\ServiceModel\Diagnostics\EventTraceActivityHelper.cs (4)
18public static bool TryAttachActivity(Message message, EventTraceActivity activity) 32public static EventTraceActivity TryExtractActivity(Message message) 37public static EventTraceActivity TryExtractActivity(Message message, bool createIfNotExist) 95private static bool GetMessageId(Message message, out Guid guid)
System\ServiceModel\Diagnostics\MessageDroppedTraceRecord.cs (1)
14internal MessageDroppedTraceRecord(Message message, EndpointAddress endpointAddress) :
System\ServiceModel\Diagnostics\MessageLogger.cs (5)
327internal static void LogMessage(ref Message message, XmlReader reader, MessageLoggingSource source) 345internal static void LogMessage(ref Message message, MessageLoggingSource source) 350static void LogMessageImpl(ref Message message, XmlReader reader, MessageLoggingSource source) 374static bool HasSecurityAction(Message message) 517static bool MatchFilters(Message message, MessageLoggingSource source)
System\ServiceModel\Diagnostics\MessageLogTraceRecord.cs (3)
38Message message; 100internal MessageLogTraceRecord(ref Message message, XmlReader reader, MessageLoggingSource source, bool logMessageBody) 123public Message Message
System\ServiceModel\Diagnostics\MessageTraceRecord.cs (3)
18Message message; 19internal MessageTraceRecord(Message message) 29protected Message Message
System\ServiceModel\Diagnostics\MessageTransmitTraceRecord.cs (8)
16MessageTransmitTraceRecord(Message message) : base(message) { } 18MessageTransmitTraceRecord(Message message, string addressElementName) 25MessageTransmitTraceRecord(Message message, string addressElementName, EndpointAddress address) 35MessageTransmitTraceRecord(Message message, string addressElementName, Uri uri) 44internal static MessageTransmitTraceRecord CreateSendTraceRecord(Message message, EndpointAddress address) 49internal static MessageTransmitTraceRecord CreateReceiveTraceRecord(Message message, Uri uri) 54internal static MessageTransmitTraceRecord CreateReceiveTraceRecord(Message message, EndpointAddress address) 59internal static MessageTransmitTraceRecord CreateReceiveTraceRecord(Message message)
System\ServiceModel\Diagnostics\PerformanceCounters.cs (2)
683static void CallOnAllCounters(string methodName, Message message, Uri listenUri, bool includeOperations) 721static internal void AuthenticationFailed(Message message, Uri listenUri)
System\ServiceModel\Diagnostics\SecurityTraceRecordHelper.cs (10)
144internal static void TraceServiceSecurityNegotiationCompleted<T>(Message message, NegotiationTokenAuthenticator<T> authenticator, SecurityContextSecurityToken serviceToken) 272internal static void TraceOutgoingMessageSecured(SecurityProtocol binding, Message message) 287internal static void TraceIncomingMessageVerified(SecurityProtocol binding, Message message) 302internal static void TraceSecureOutgoingMessageFailure(SecurityProtocol binding, Message message) 311internal static void TraceVerifyIncomingMessageFailure(SecurityProtocol binding, Message message) 434internal static void TraceSessionRenewalFaultSent(SecurityContextSecurityToken sessionToken, Uri listenAddress, Message message) 713Message message; 724public ServerSessionTraceRecord(SecurityContextSecurityToken currentSessionToken, Message message, Uri listenAddress) 877Message message; 879public MessageSecurityTraceRecord(SecurityProtocol binding, Message message)
System\ServiceModel\Diagnostics\ServiceModelPerformanceCounters.cs (1)
85internal OperationPerformanceCountersBase GetOperationPerformanceCountersFromMessage(Message message)
System\ServiceModel\Diagnostics\TraceUtility.cs (22)
484static internal void AddActivityHeader(Message message) 503static internal void AddAmbientActivityToMessage(Message message) 522static internal void CopyActivity(Message source, Message destination) 540internal static ServiceModelActivity ExtractActivity(Message message) 576internal static Guid ExtractActivityId(Message message) 600internal static ServiceModelActivity ExtractAndRemoveActivity(Message message) 612internal static void ProcessIncomingMessage(Message message, EventTraceActivity eventTraceActivity) 639internal static void ProcessOutgoingMessage(Message message, EventTraceActivity eventTraceActivity) 659internal static void SetActivity(Message message, ServiceModelActivity activity) 667internal static void TraceDroppedMessage(Message message, EndpointDispatcher dispatcher) 701internal static void TraceEvent(TraceEventType severity, int traceCode, string traceDescription, Message message) 713internal static void TraceEvent(TraceEventType severity, int traceCode, string traceDescription, object source, Message message) 722internal static void TraceEvent(TraceEventType severity, int traceCode, string traceDescription, Exception exception, Message message) 748internal static void TraceEvent(TraceEventType severity, int traceCode, string traceDescription, TraceRecord extendedData, object source, Exception exception, Message message) 816internal static Exception ThrowHelperError(Exception exception, Message message) 838internal static Exception ThrowHelperWarning(Exception exception, Message message) 849internal static ArgumentException ThrowHelperArgument(string paramName, string message, Message msg) 854internal static ArgumentNullException ThrowHelperArgumentNull(string paramName, Message message) 1018static internal void MessageFlowAtMessageSent(Message message, EventTraceActivity eventTraceActivity) 1041static internal void MessageFlowAtMessageReceived(Message message, OperationContext context, EventTraceActivity eventTraceActivity, bool createNewActivityId) 1097internal static void TransferFromTransport(Message message)
System\ServiceModel\Dispatcher\ActionMessageFilter.cs (3)
79bool InnerMatch(Message message) 90public override bool Match(Message message) 107Message msg = messageBuffer.CreateMessage();
System\ServiceModel\Dispatcher\ActionMessageFilterTable.cs (11)
180MessageFilter InnerMatch(Message message) 214void InnerMatch(Message message, ICollection<MessageFilter> results) 237void InnerMatchData(Message message, ICollection<TFilterData> results) 260public bool GetMatchingValue(Message message, out TFilterData data) 286Message msg = messageBuffer.CreateMessage(); 306public bool GetMatchingFilter(Message message, out MessageFilter filter) 324Message msg = messageBuffer.CreateMessage(); 336public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results) 365Message msg = messageBuffer.CreateMessage(); 378public bool GetMatchingValues(Message message, ICollection<TFilterData> results) 407Message msg = messageBuffer.CreateMessage();
System\ServiceModel\Dispatcher\AndMessageFilter.cs (2)
45public override bool Match(Message message) 55internal bool Match(Message message, out bool addressMatched)
System\ServiceModel\Dispatcher\AndMessageFilterTable.cs (8)
143FilterDataPair InnerMatch(Message message) 191void InnerMatch(Message message, ICollection<MessageFilter> results) 205void InnerMatchData(Message message, ICollection<FilterData> results) 247internal bool GetMatchingValue(Message message, out FilterData data, out bool addressMatched) 283public bool GetMatchingValue(Message message, out FilterData data) 320public bool GetMatchingFilter(Message message, out MessageFilter filter) 357public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results) 391public bool GetMatchingValues(Message message, ICollection<FilterData> results)
System\ServiceModel\Dispatcher\BufferedReceiveBinder.cs (7)
124public RequestContext CreateRequestContext(Message message) 129public void Send(Message message, TimeSpan timeout) 134public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 144public Message Request(Message message, TimeSpan timeout) 149public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 154public Message EndRequest(IAsyncResult result)
System\ServiceModel\Dispatcher\ChannelDispatcher.cs (1)
545internal EndpointDispatcher Match(Message message, out bool addressMatched)
System\ServiceModel\Dispatcher\ChannelHandler.cs (16)
400Message message; 517Message message = Message.CreateMessage(this.Binder.Channel.GetProperty<MessageVersion>(), OperationDescription.SessionOpenedAction); 645ServiceChannel GetDatagramChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched) 670EndpointDispatcher GetEndpointDispatcher(Message message, out bool addressMatched) 675ServiceChannel GetSessionChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched) 1192Message fault = Message.CreateMessage(this.messageVersion, code, reason, action); 1204Message fault = Message.CreateMessage(this.messageVersion, code, reason, action); 1208void ReplyFailure(RequestContext request, Message fault, string action, string reason, FaultCode code) 1253Message reply = faultInfo.Fault; 1309bool PrepareReply(RequestContext request, Message reply) 1320Message requestMessage = null; 2057EventTraceActivity TraceDispatchMessageStart(Message message) 2080public Message Reply;
System\ServiceModel\Dispatcher\ClientRuntime.cs (3)
445internal bool IsFault(ref Message reply) 463internal static bool IsMessageVersionNoneFault(ref Message message, int maxFaultSize) 478using (Message copy = buffer.CreateMessage())
System\ServiceModel\Dispatcher\DataContractSerializerOperationFormatter.cs (2)
169protected override void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest) 271protected override void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest)
System\ServiceModel\Dispatcher\DispatchOperationRuntime.cs (2)
750Message reply; 806reply = (Message)rpc.ReturnParameter;
System\ServiceModel\Dispatcher\DispatchRuntime.cs (5)
713internal DispatchOperationRuntime GetOperation(ref Message message) 799Message message = inputs[0] as Message; 848return Message.CreateMessage(message.Version, fault, message.Version.Addressing.DefaultFaultAction); 979object IInstanceProvider.GetInstance(InstanceContext instanceContext, Message message)
System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (39)
268internal bool HandleRequestAsReply(Message message) 289bool HandleRequestAsReplyCore(Message message) 332Message message; 353public RequestContext CreateRequestContext(Message message) 358public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 368public void Send(Message message, TimeSpan timeout) 373public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 414public Message EndRequest(IAsyncResult result) 433Message message; 454public Message Request(Message message, TimeSpan timeout) 493Message reply; 548void RequestStarting(Message message, IDuplexRequest request) 638void EnsureIncomingIdentity(SecurityMessageProperty property, EndpointAddress address, Message reply) 643void ThrowIfInvalidReplyIdentity(Message reply) 677internal DuplexRequestContext(IDuplexChannel channel, Message request, DuplexChannelBinder binder) 692protected override void OnReply(Message message, TimeSpan timeout) 700protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 715public ReplyAsyncResult(DuplexRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state) 773void GotReply(Message reply); 778Message reply; 808internal Message WaitForReply(TimeSpan timeout) 826public void GotReply(Message reply) 872Message reply; 879internal AsyncDuplexRequest(Message message, DuplexChannelBinder parent, TimeSpan timeout, AsyncCallback callback, object state) 1018internal Message End() 1025public void GotReply(Message reply) 1104InputQueue<Message> pendingMessages; 1111this.pendingMessages = new InputQueue<Message>(); 1270Message message = null; 1387public Message Receive() 1392public Message Receive(TimeSpan timeout) 1407public Message EndReceive(IAsyncResult result) 1412public bool TryReceive(TimeSpan timeout, out Message message) 1422public bool EndTryReceive(IAsyncResult result, out Message message) 1546public void Send(Message message) 1551public void Send(Message message, TimeSpan timeout) 1556public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 1561public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Dispatcher\EndpointAddressMessageFilter.cs (3)
76Message msg = messageBuffer.CreateMessage(); 87public override bool Match(Message message) 305internal bool Match(Message message)
System\ServiceModel\Dispatcher\EndpointAddressMessageFilterTable.cs (14)
337Candidate InnerMatch(Message message) 370Candidate GetSingleMatch(CandidateSet cset, Message message) 420void InnerMatchData(Message message, ICollection<TFilterData> results) 437void InnerMatchData(Message message, ICollection<TFilterData> results, CandidateSet cset) 454protected void InnerMatchFilters(Message message, ICollection<MessageFilter> results) 471void InnerMatchFilters(Message message, ICollection<MessageFilter> results, CandidateSet cset) 488public bool GetMatchingValue(Message message, out TFilterData data) 513Message msg = messageBuffer.CreateMessage(); 534public bool GetMatchingValues(Message message, ICollection<TFilterData> results) 563Message msg = messageBuffer.CreateMessage(); 576public bool GetMatchingFilter(Message message, out MessageFilter filter) 601Message msg = messageBuffer.CreateMessage(); 622public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results) 651Message msg = messageBuffer.CreateMessage();
System\ServiceModel\Dispatcher\EndpointAddressProcessor.cs (1)
188internal void ProcessHeaders(Message msg, Dictionary<QName, int> qnameLookup, Dictionary<string, HeaderBit[]> headerLookup)
System\ServiceModel\Dispatcher\EndpointDispatcherTable.cs (2)
98EndpointDispatcher LookupInCache(Message message, out bool addressMatched) 151public EndpointDispatcher Lookup(Message message, out bool addressMatched)
System\ServiceModel\Dispatcher\ErrorBehavior.cs (7)
40rpc.FaultInfo.Fault = Message.CreateMessage(rpc.RequestVersion, messageFault, action); 93faultInfo.Fault = Message.CreateMessage(this.messageVersion, fault, action); 129Message m = faultInfo.Fault; 142Message faultMessage; 154faultInfo.Fault = Message.CreateMessage(this.messageVersion, MessageFault.CreateFault(ndfe.Code, ndfe.Reason, detail), ndfe.Action); 158faultInfo.Fault = Message.CreateMessage(this.messageVersion, ndfe.CreateMessageFault(), ndfe.Action); 243internal static void ThrowAndCatch(Exception e, Message message)
System\ServiceModel\Dispatcher\ErrorHandlerFaultInfo.cs (2)
14Message fault; // if this is null, then we aren't interested in sending back a fault 25public Message Fault
System\ServiceModel\Dispatcher\HeaderFilter.cs (1)
29Message message = buffer.CreateMessage();
System\ServiceModel\Dispatcher\ICallContextInitializer.cs (1)
13object BeforeInvoke(InstanceContext instanceContext, IClientChannel channel, Message message);
System\ServiceModel\Dispatcher\IChannelBinder.cs (7)
26void Send(Message message, TimeSpan timeout); 27IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state); 30Message Request(Message message, TimeSpan timeout); 31IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state); 32Message EndRequest(IAsyncResult result); 38RequestContext CreateRequestContext(Message message);
System\ServiceModel\Dispatcher\IClientMessageFormatter.cs (2)
13Message SerializeRequest(MessageVersion messageVersion, object[] parameters); 14object DeserializeReply(Message message, object[] parameters);
System\ServiceModel\Dispatcher\IClientMessageInspector.cs (2)
13object BeforeSendRequest(ref Message request, IClientChannel channel); 14void AfterReceiveReply(ref Message reply, object correlationState);
System\ServiceModel\Dispatcher\IDispatchMessageFormatter.cs (2)
13void DeserializeRequest(Message message, object[] parameters); 14Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result);
System\ServiceModel\Dispatcher\IDispatchMessageInspector.cs (2)
13object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext); 14void BeforeSendReply(ref Message reply, object correlationState);
System\ServiceModel\Dispatcher\IDispatchOperationSelector.cs (1)
12string SelectOperation(ref Message message);
System\ServiceModel\Dispatcher\IErrorHandler.cs (1)
12void ProvideFault(Exception error, MessageVersion version, ref Message fault);
System\ServiceModel\Dispatcher\IInstanceContextInitializer.cs (1)
14void Initialize(InstanceContext instanceContext, Message message);
System\ServiceModel\Dispatcher\IInstanceContextProvider.cs (4)
13InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel); 14void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel); 79public virtual InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel) 84public virtual void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel)
System\ServiceModel\Dispatcher\IInstanceProvider.cs (1)
14object 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 (15)
310Message originalReply = rpc.Reply; 311Message reply = originalReply; 358Message reply = rpc.Reply; 407Message reply = rpc.Reply; 714void AddMessageProperties(Message message, OperationContext context, ServiceChannel replyChannel) 876internal DispatchOperationRuntime GetOperation(ref Message message) 1735DispatchOperationRuntime GetOperation(ref Message request); 1763public DispatchOperationRuntime GetOperation(ref Message request) 1802public DispatchOperationRuntime GetOperation(ref Message request) 1862protected override IAsyncResult OnBeginFinalizeCorrelation(Message message, TimeSpan timeout, 1881protected override Message OnEndFinalizeCorrelation(IAsyncResult result) 1889Message message = this.innerCallback.EndFinalizeCorrelation(result); 1900protected override Message OnFinalizeCorrelation(Message message, TimeSpan timeout) 1908Message newMessage = this.innerCallback.FinalizeCorrelation(message, timeout);
System\ServiceModel\Dispatcher\InputChannelBinder.cs (13)
75Message message; 88public RequestContext CreateRequestContext(Message message) 93public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 103public void Send(Message message, TimeSpan timeout) 110Message message; 123public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 128public Message EndRequest(IAsyncResult result) 133public Message Request(Message message, TimeSpan timeout) 153RequestContext WrapMessage(Message message) 169internal InputRequestContext(Message request, InputChannelBinder binder) 183protected override void OnReply(Message message, TimeSpan timeout) 187protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Dispatcher\InstanceBehavior.cs (3)
234internal object GetInstance(InstanceContext instanceContext, Message request) 261Message message = (current != null) ? current.IncomingMessage : null; 344public object GetInstance(InstanceContext instanceContext, Message message)
System\ServiceModel\Dispatcher\MatchAllMessageFilter.cs (1)
28public override bool Match(Message message)
System\ServiceModel\Dispatcher\MatchNoneMessageFilter.cs (1)
28public override bool Match(Message message)
System\ServiceModel\Dispatcher\MessageFilter.cs (5)
48public abstract bool Match(Message message); 77public bool GetMatchingValue(Message message, out FilterData data) 129public bool GetMatchingValues(Message message, ICollection<FilterData> results) 155public bool GetMatchingFilter(Message message, out MessageFilter filter) 199public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results)
System\ServiceModel\Dispatcher\MessageFilterTable.cs (6)
278public bool GetMatchingValue(Message message, out TFilterData data) 310internal bool GetMatchingValue(Message message, out TFilterData data, out bool addressMatched) 362internal bool GetMatchingValue(MessageBuffer buffer, Message messageToReadHeaders, out TFilterData data) 403public bool GetMatchingValues(Message message, ICollection<TFilterData> results) 447public bool GetMatchingFilter(Message message, out MessageFilter filter) 513public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results)
System\ServiceModel\Dispatcher\MessageOperationFormatter.cs (8)
27public object DeserializeReply(Message message, object[] parameters) 37public void DeserializeRequest(Message message, object[] parameters) 60public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 62if (!(result is Message)) 67return (Message)result; 70public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 74if (parameters.Length != 1 || !(parameters[0] is Message)) 77return (Message)parameters[0];
System\ServiceModel\Dispatcher\MessageQuery.cs (1)
16public abstract TResult Evaluate<TResult>(Message message);
System\ServiceModel\Dispatcher\MessageQueryCollection.cs (1)
13public abstract IEnumerable<KeyValuePair<MessageQuery, TResult>> Evaluate<TResult>(Message message);
System\ServiceModel\Dispatcher\MessageQueryTable.cs (6)
111public IEnumerable<KeyValuePair<MessageQuery, TResult>> Evaluate<TResult>(Message message) 177public override IEnumerable<KeyValuePair<MessageQuery, TResult>> Evaluate<TResult>(Message message) 272class MessageSequentialResultEnumerable<TResult> : SequentialResultEnumerable<Message, TResult> 275SequentialMessageQueryCollection collection, Message message) 404class MessageEnumerable<TResult> : Enumerable<Message, TResult> 406public MessageEnumerable(MessageQueryTable<TItem> table, Message message)
System\ServiceModel\Dispatcher\MessageRpc.cs (3)
54internal Message Request; 58internal Message Reply; 81internal MessageRpc(RequestContext requestContext, Message request, DispatchOperationRuntime operation,
System\ServiceModel\Dispatcher\MultipleReceiveBinder.cs (7)
187public RequestContext CreateRequestContext(Message message) 192public void Send(Message message, TimeSpan timeout) 197public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 207public Message Request(Message message, TimeSpan timeout) 212public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 217public Message EndRequest(IAsyncResult result)
System\ServiceModel\Dispatcher\OperationFormatter.cs (14)
52protected abstract void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest); 54protected abstract void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest); 105public object DeserializeReply(Message message, object[] parameters) 173public void DeserializeRequest(Message message, object[] parameters) 227object DeserializeBodyContents(Message message, object[] parameters, bool isRequest) 257public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 278Message msg = new OperationFormatterMessage(this, messageVersion, 287public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 319Message msg = new OperationFormatterMessage(this, messageVersion, 418void AddPropertiesToMessage(Message message, MessageDescription messageDescription, object[] parameters) 426void AddPropertiesToMessageCore(Message message, MessageDescription messageDescription, object[] parameters) 439void GetPropertiesFromMessage(Message message, MessageDescription messageDescription, object[] parameters) 447void GetPropertiesFromMessageCore(Message message, MessageDescription messageDescription, object[] parameters) 778public override Message CreateMessage()
System\ServiceModel\Dispatcher\OutputChannelBinder.cs (7)
76public RequestContext CreateRequestContext(Message message) 81public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 91public void Send(Message message, TimeSpan timeout) 96public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 101public Message EndRequest(IAsyncResult result) 111public Message Request(Message message, TimeSpan timeout)
System\ServiceModel\Dispatcher\PerCallInstanceContextProvider.cs (2)
20public override InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel) 26public override void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel)
System\ServiceModel\Dispatcher\PerSessionInstanceContextProvider.cs (2)
19public override InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel) 34public override void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel)
System\ServiceModel\Dispatcher\PrefixEndpointAddressMessageFilter.cs (2)
69Message msg = messageBuffer.CreateMessage(); 80public override bool Match(Message message)
System\ServiceModel\Dispatcher\PrimitiveOperationFormatter.cs (6)
389public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 397return Message.CreateMessage(messageVersion, GetActionHeader(messageVersion.Addressing), new PrimitiveRequestBodyWriter(parameters, this)); 400public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 408return Message.CreateMessage(messageVersion, GetReplyActionHeader(messageVersion.Addressing), new PrimitiveResponseBodyWriter(parameters, result, this)); 411public object DeserializeReply(Message message, object[] parameters) 451public void DeserializeRequest(Message message, object[] parameters)
System\ServiceModel\Dispatcher\ProxyOperationRuntime.cs (3)
164Message reply = rpc.Reply; 331rpc.Request = (Message)rpc.InputParameters[0]; 464static internal bool IsValidAction(Message message, string action)
System\ServiceModel\Dispatcher\ProxyRpc.cs (2)
23internal Message Request; 24internal Message Reply;
System\ServiceModel\Dispatcher\QueryMatcher.cs (9)
94Message message; 96internal QueryResult(QueryMatcher matcher, Message message, bool evalBody) 440internal SeekableXPathNavigator CreateMessageNavigator(Message message, bool matchBody) 504Message message = messageBuffer.CreateMessage(); 518internal FilterResult Match(Message message, bool matchBody, ICollection<MessageFilter> matches) 541Message message = messageBuffer.CreateMessage(); 545internal QueryResult<TResult> Evaluate<TResult>(Message message, bool matchBody) 769Message message = messageBuffer.CreateMessage(); 783internal FilterResult Match(Message message, bool matchBody)
System\ServiceModel\Dispatcher\QueryProcessor.cs (3)
434Message message; 531internal Message ContextMessage 874internal void Eval(Opcode block, Message message, bool matchBody)
System\ServiceModel\Dispatcher\ReplyChannelBinder.cs (7)
78public RequestContext CreateRequestContext(Message message) 83public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 93public void Send(Message message, TimeSpan timeout) 98public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 103public Message EndRequest(IAsyncResult result) 113public Message Request(Message message, TimeSpan timeout)
System\ServiceModel\Dispatcher\RequestChannelBinder.cs (8)
71public RequestContext CreateRequestContext(Message message) 76public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 86public void Send(Message message, TimeSpan timeout) 91public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 96public Message EndRequest(IAsyncResult result) 106public Message Request(Message message, TimeSpan timeout) 111void ValidateNullReply(Message message)
System\ServiceModel\Dispatcher\SeekableMessageNavigator.cs (4)
50Message message; 134internal SeekableMessageNavigator(Message msg, int countMax, XmlSpace space, bool includeBody, bool atomize) 246internal Message Message 1140internal void Init(Message msg, int countMax, XmlSpace space, bool includeBody, bool atomize)
System\ServiceModel\Dispatcher\SingletonInstanceContextProvider.cs (2)
68public override InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel) 78public override void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel)
System\ServiceModel\Dispatcher\StreamFormatter.cs (3)
123internal void Deserialize(object[] parameters, ref object retVal, Message message) 219Message message; 225internal MessageBodyStream(Message message, string wrapperName, string wrapperNs, string elementName, string elementNs, bool isRequest)
System\ServiceModel\Dispatcher\ThreadSafeMessageFilterTable.cs (4)
78public bool GetMatchingValue(Message message, out FilterData data) 94public bool GetMatchingValues(Message message, ICollection<FilterData> results) 110public bool GetMatchingFilter(Message message, out MessageFilter filter) 126public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results)
System\ServiceModel\Dispatcher\XmlSerializerOperationFormatter.cs (2)
43protected override void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest) 137protected override void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest)
System\ServiceModel\Dispatcher\XPathMessageContext.cs (6)
622Message msg = context.Processor.ContextMessage; 695Message msg = context.Processor.ContextMessage; 758Message msg = context.Processor.ContextMessage; 915Message msg = context.Processor.ContextMessage; 1607Message message = context.Processor.ContextMessage; 1632Message message = nav.Message;
System\ServiceModel\Dispatcher\XPathMessageFilter.cs (1)
369public override bool Match(Message message)
System\ServiceModel\Dispatcher\XPathMessageFilterTable.cs (4)
233public bool GetMatchingValue(Message message, out TFilterData data) 297public bool GetMatchingFilter(Message message, out MessageFilter filter) 377public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results) 457public bool GetMatchingValues(Message message, ICollection<TFilterData> results)
System\ServiceModel\Dispatcher\XPathMessageQueryCollection.cs (1)
21public override IEnumerable<KeyValuePair<MessageQuery, TResult>> Evaluate<TResult>(Message message)
System\ServiceModel\EndpointAddress.cs (1)
304public void ApplyTo(Message message)
System\ServiceModel\InstanceContext.cs (1)
461public object GetServiceInstance(Message message)
System\ServiceModel\MessageHeaderException.cs (3)
60internal Message ProvideFault(MessageVersion messageVersion) 64Message message = System.ServiceModel.Channels.Message.CreateMessage(messageVersion, phf, AddressingVersion.WSAddressing10.FaultAction);
System\ServiceModel\MsmqIntegration\MsmqIntegrationInputChannel.cs (1)
16protected override Message DecodeMsmqMessage(MsmqInputMessage msmqMessage, MsmqMessageProperty property)
System\ServiceModel\MsmqIntegration\MsmqIntegrationMessageProperty.cs (1)
14public static MsmqIntegrationMessageProperty Get(System.ServiceModel.Channels.Message message)
System\ServiceModel\MsmqIntegration\MsmqIntegrationOutputChannel.cs (2)
116protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 127protected override void OnSend(Message message, TimeSpan timeout)
System\ServiceModel\MustUnderstandSoapException.cs (3)
34internal Message ProvideFault(MessageVersion messageVersion) 42Message message = System.ServiceModel.Channels.Message.CreateMessage(messageVersion, fault, faultAction);
System\ServiceModel\OperationContext.cs (10)
24Message clientReply; 29Message request; 80internal OperationContext(RequestContext requestContext, Message request, ServiceChannel channel, ServiceHostBase host) 189internal Message IncomingMessage 241Message message = this.clientReply ?? this.request; 253Message message = this.clientReply ?? this.request; 265Message message = this.clientReply ?? this.request; 413internal void ReInit(RequestContext requestContext, Message request, ServiceChannel channel) 431internal void SetClientReply(Message message, bool closeMessage) 433Message oldClientReply = null;
System\ServiceModel\PeerMessagePropagationFilter.cs (1)
10public abstract PeerMessagePropagation ShouldMessagePropagate(Message message, PeerMessageOrigination origination);
System\ServiceModel\ProtocolException.cs (2)
19internal static ProtocolException ReceiveShutdownReturnedNonNull(Message message) 43internal static ProtocolException OneWayOperationReturnedNonNull(Message message)
System\ServiceModel\Security\AcceleratedTokenAuthenticator.cs (3)
161protected override BodyWriter ProcessRequestSecurityToken(Message request, RequestSecurityToken requestSecurityToken, out NegotiationTokenAuthenticatorState negotiationState) 294protected override BodyWriter ProcessRequestSecurityTokenResponse(NegotiationTokenAuthenticatorState negotiationState, Message request, RequestSecurityTokenResponse requestSecurityTokenResponse) 310public override bool Match(Message message)
System\ServiceModel\Security\AcceleratedTokenProvider.cs (1)
267protected override BodyWriter GetNextOutgoingMessageBody(Message incomingMessage, AcceleratedTokenProviderState negotiationState)
System\ServiceModel\Security\AcceptorSessionSymmetricMessageSecurityProtocol.cs (7)
142protected override IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state) 149return new CompletedAsyncResult<Message>(message, callback, state); 152protected override SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 162protected override void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState) 164message = CompletedAsyncResult<Message>.End(result); 168void SetUpDelayedSecurityExecution(ref Message message, SecurityToken signingToken, SecurityToken encryptionToken, 184protected override SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates)
System\ServiceModel\Security\AcceptorSessionSymmetricTransportSecurityProtocol.cs (1)
82protected override void VerifyIncomingMessageCore(ref Message message, TimeSpan timeout)
System\ServiceModel\Security\ApplySecurityAndSendAsyncResult.cs (4)
40protected void Begin(Message message, SecurityProtocolCorrelationState correlationState) 59bool OnSecureOutgoingMessageComplete(Message message) 75protected abstract IAsyncResult BeginSendCore(MessageSenderType channel, Message message, TimeSpan timeout, AsyncCallback callback, object state); 109Message message;
System\ServiceModel\Security\AsymmetricSecurityProtocol.cs (13)
145protected override IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state) 155return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state); 172protected override void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState) 174if (result is CompletedAsyncResult<Message, SecurityProtocolCorrelationState>) 176message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState); 184protected override SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 195void SetUpDelayedSecurityExecution(ref Message message, SecurityToken encryptingToken, SecurityToken signingToken, 222void AttachRecipientSecurityProperty(Message message, SecurityToken initiatorToken, SecurityToken recipientToken, IList<SecurityToken> basicTokens, IList<SecurityToken> endorsingTokens, 232void DoIdentityCheckAndAttachInitiatorSecurityProperty(Message message, SecurityToken initiatorToken, SecurityToken recipientToken, ReadOnlyCollection<IAuthorizationPolicy> recipientTokenPolicies) 241protected override SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates) 320bool TryGetTokenSynchronouslyForOutgoingSecurity(Message message, SecurityProtocolCorrelationState correlationState, bool isBlockingCall, TimeSpan timeout, 361public SecureOutgoingMessageAsyncResult(Message m, AsymmetricSecurityProtocol binding, 369protected override void OnBothGetTokenCallsDone(ref Message message, SecurityToken primaryToken, SecurityToken secondaryToken, TimeSpan timeout)
System\ServiceModel\Security\DuplexSecurityProtocolFactory.cs (12)
230public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state) 238return new CompletedAsyncResult<Message>(message, callback, state); 242public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, 251return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, null, callback, state); 255public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message) 263message = CompletedAsyncResult<Message>.End(result); 268out Message message, out SecurityProtocolCorrelationState newCorrelationState) 276message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState); 280public override void SecureOutgoingMessage(ref Message message, TimeSpan timeout) 288public override SecurityProtocolCorrelationState SecureOutgoingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 300public override void VerifyIncomingMessage(ref Message message, TimeSpan timeout) 308public override SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout,
System\ServiceModel\Security\IdentityVerifier.cs (1)
37internal bool CheckAccess(EndpointAddress reference, Message message)
System\ServiceModel\Security\ImpersonateOnSerializingReplyMessageProperty.cs (1)
44public static bool TryGet(Message message, out ImpersonateOnSerializingReplyMessageProperty property)
System\ServiceModel\Security\ImpersonatingMessage.cs (2)
12Message innerMessage; 14public ImpersonatingMessage(Message innerMessage)
System\ServiceModel\Security\InitiatorSessionSymmetricMessageSecurityProtocol.cs (11)
157protected override IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state) 170return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state); 190protected override SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 204protected override void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState) 206if (result is CompletedAsyncResult<Message, SecurityProtocolCorrelationState>) 208message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState); 216internal void SetUpDelayedSecurityExecution(ref Message message, SecurityToken signingToken, SecurityToken encryptionToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters, 237protected override SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates) 273Message message; 281public SecureOutgoingMessageAsyncResult(Message message, InitiatorSessionSymmetricMessageSecurityProtocol binding, SecurityToken signingToken, SecurityToken encryptionToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters, TimeSpan timeout, AsyncCallback callback, object state) 300internal static Message End(IAsyncResult result, out SecurityProtocolCorrelationState newCorrelationState)
System\ServiceModel\Security\InitiatorSessionSymmetricTransportSecurityProtocol.cs (10)
127internal void SetupDelayedSecurityExecution(string actor, ref Message message, SecurityToken signingToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters, 141protected override void SecureOutgoingMessageAtInitiator(ref Message message, string actor, TimeSpan timeout) 152protected override IAsyncResult BeginSecureOutgoingMessageAtInitiatorCore(Message message, string actor, TimeSpan timeout, AsyncCallback callback, object state) 167return new CompletedAsyncResult<Message>(message, callback, state); 171protected override Message EndSecureOutgoingMessageAtInitiatorCore(IAsyncResult result) 173if (result is CompletedAsyncResult<Message>) 175return CompletedAsyncResult<Message>.End(result); 185Message message; 192public SecureOutgoingMessageAsyncResult(string actor, Message message, InitiatorSessionSymmetricTransportSecurityProtocol binding, SecurityToken signingToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters, TimeSpan timeout, AsyncCallback callback, object state) 210internal static Message End(IAsyncResult result)
System\ServiceModel\Security\IssuanceTokenProviderBase.cs (15)
345static protected void ThrowIfFault(Message message, EndpointAddress target) 423protected abstract BodyWriter GetNextOutgoingMessageBody(Message incomingMessage, T negotiationState); 430void PrepareRequest(Message nextMessage) 435void PrepareRequest(Message nextMessage, RequestSecurityToken rst) 479Message nextOutgoingMessage = null; 480Message incomingMessage = null; 590Message GetNextOutgoingMessage(Message incomingMessage, T negotiationState) 604Message nextMessage; 607nextMessage = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.RequestSecurityTokenAction, this.MessageVersion.Addressing), nextMessageBody); 611nextMessage = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.RequestSecurityTokenResponseAction, this.MessageVersion.Addressing), nextMessageBody); 756Message nextOutgoingMessage; 966Message incomingMessage = null; 1012Message incomingMessage = null; 1054bool DoNegotiation(Message incomingMessage)
System\ServiceModel\Security\IssuedTokensHeader.cs (2)
183internal static Collection<RequestSecurityTokenResponse> ExtractIssuances(Message message, MessageSecurityVersion version, WSSecurityTokenSerializer tokenSerializer, string[] actors, XmlQualifiedName expectedAppliesToQName) 189internal static Collection<RequestSecurityTokenResponse> ExtractIssuances(Message message, SecurityStandardsManager standardsManager, string[] actors, XmlQualifiedName expectedAppliesToQName)
System\ServiceModel\Security\IWSTrust13AsyncContract.cs (16)
26IAsyncResult BeginTrust13Cancel( Message request, AsyncCallback callback, object state ); 33Message EndTrust13Cancel( IAsyncResult ar ); 43IAsyncResult BeginTrust13Issue( Message request, AsyncCallback callback, object state ); 50Message EndTrust13Issue( IAsyncResult ar ); 61IAsyncResult BeginTrust13Renew( Message request, AsyncCallback callback, object state ); 68Message EndTrust13Renew( IAsyncResult ar ); 79IAsyncResult BeginTrust13Validate( Message request, AsyncCallback callback, object state ); 86Message EndTrust13Validate( IAsyncResult ar ); 101IAsyncResult BeginTrust13CancelResponse( Message request, AsyncCallback callback, object state ); 108Message EndTrust13CancelResponse( IAsyncResult ar ); 124IAsyncResult BeginTrust13IssueResponse( Message request, AsyncCallback callback, object state ); 131Message EndTrust13IssueResponse( IAsyncResult ar ); 147IAsyncResult BeginTrust13RenewResponse( Message request, AsyncCallback callback, object state ); 154Message EndTrust13RenewResponse( IAsyncResult ar ); 170IAsyncResult BeginTrust13ValidateResponse( Message request, AsyncCallback callback, object state ); 177Message EndTrust13ValidateResponse( IAsyncResult ar );
System\ServiceModel\Security\IWSTrust13SyncContract.cs (16)
23Message ProcessTrust13Cancel( Message message ); 31Message ProcessTrust13Issue( Message message ); 39Message ProcessTrust13Renew( Message message ); 47Message ProcessTrust13Validate( Message message ); 60Message ProcessTrust13CancelResponse( Message message ); 73Message ProcessTrust13IssueResponse( Message message ); 86Message ProcessTrust13RenewResponse( Message message ); 99Message ProcessTrust13ValidateResponse( Message message );
System\ServiceModel\Security\IWSTrustContract.cs (16)
23Message Cancel(Message message); 33IAsyncResult BeginCancel(Message message, AsyncCallback callback, object asyncState); 40Message EndCancel(IAsyncResult asyncResult); 48Message Issue(Message message); 58IAsyncResult BeginIssue(Message message, AsyncCallback callback, object asyncState); 65Message EndIssue(IAsyncResult asyncResult); 73Message Renew(Message message); 83IAsyncResult BeginRenew(Message message, AsyncCallback callback, object asyncState); 90Message EndRenew(IAsyncResult asyncResult); 98Message Validate(Message message); 108IAsyncResult BeginValidate(Message message, AsyncCallback callback, object asyncState); 115Message EndValidate(IAsyncResult asyncResult);
System\ServiceModel\Security\IWSTrustFeb2005AsyncContract.cs (16)
26IAsyncResult BeginTrustFeb2005Cancel( Message request, AsyncCallback callback, object state ); 33Message EndTrustFeb2005Cancel( IAsyncResult ar ); 43IAsyncResult BeginTrustFeb2005Issue( Message request, AsyncCallback callback, object state ); 50Message EndTrustFeb2005Issue( IAsyncResult ar ); 60IAsyncResult BeginTrustFeb2005Renew( Message request, AsyncCallback callback, object state ); 67Message EndTrustFeb2005Renew( IAsyncResult ar ); 77IAsyncResult BeginTrustFeb2005Validate( Message request, AsyncCallback callback, object state ); 84Message EndTrustFeb2005Validate( IAsyncResult ar ); 94IAsyncResult BeginTrustFeb2005CancelResponse( Message request, AsyncCallback callback, object state ); 101Message EndTrustFeb2005CancelResponse( IAsyncResult ar ); 111IAsyncResult BeginTrustFeb2005IssueResponse( Message request, AsyncCallback callback, object state ); 118Message EndTrustFeb2005IssueResponse( IAsyncResult ar ); 128IAsyncResult BeginTrustFeb2005RenewResponse( Message request, AsyncCallback callback, object state ); 135Message EndTrustFeb2005RenewResponse( IAsyncResult ar ); 145IAsyncResult BeginTrustFeb2005ValidateResponse( Message request, AsyncCallback callback, object state ); 152Message EndTrustFeb2005ValidateResponse( IAsyncResult ar );
System\ServiceModel\Security\IWSTrustFeb2005SyncContract.cs (16)
23Message ProcessTrustFeb2005Cancel( Message message ); 31Message ProcessTrustFeb2005Issue( Message message ); 39Message ProcessTrustFeb2005Renew( Message message ); 47Message ProcessTrustFeb2005Validate( Message message ); 55Message ProcessTrustFeb2005CancelResponse( Message message ); 63Message ProcessTrustFeb2005IssueResponse( Message message ); 71Message ProcessTrustFeb2005RenewResponse( Message message ); 79Message ProcessTrustFeb2005ValidateResponse( Message message );
System\ServiceModel\Security\MessageSecurityProtocol.cs (33)
48protected bool RequiresIncomingSecurityProcessing(Message message) 79public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state) 87return new CompletedAsyncResult<Message>(message, callback, state); 101public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state) 109return new CompletedAsyncResult<Message>(message, callback, state); 123protected abstract IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state); 125public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message) 147public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState) 168protected abstract void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState); 171protected void AttachRecipientSecurityProperty(Message message, SecurityToken protectionToken, bool isWrappedToken, IList<SecurityToken> basicTokens, IList<SecurityToken> endorsingTokens, 190protected void DoIdentityCheckAndAttachInitiatorSecurityProperty(Message message, SecurityToken protectionToken, ReadOnlyCollection<IAuthorizationPolicy> protectionTokenPolicies) 198protected AuthorizationContext EnsureIncomingIdentity(Message message, SecurityToken token, ReadOnlyCollection<IAuthorizationPolicy> authorizationPolicies) 290protected static void EnsureNonWrappedToken(SecurityToken token, Message message) 308protected SendSecurityHeader ConfigureSendSecurityHeader(Message message, string actor, IList<SupportingTokenSpecification> supportingTokens, SecurityProtocolCorrelationState correlationState) 345protected ReceiveSecurityHeader CreateSecurityHeader(Message message, string actor, MessageDirection transferDirection, SecurityStandardsManager standardsManager) 376protected ReceiveSecurityHeader ConfigureReceiveSecurityHeader(Message message, string actor, SecurityProtocolCorrelationState[] correlationStates, out IList<SupportingTokenAuthenticatorSpecification> supportingAuthenticators) 381protected ReceiveSecurityHeader ConfigureReceiveSecurityHeader(Message message, string actor, SecurityProtocolCorrelationState[] correlationStates, SecurityStandardsManager standardsManager, out IList<SupportingTokenAuthenticatorSpecification> supportingAuthenticators) 425protected void ProcessSecurityHeader(ReceiveSecurityHeader securityHeader, ref Message message, 524public override void SecureOutgoingMessage(ref Message message, TimeSpan timeout) 548public override SecurityProtocolCorrelationState SecureOutgoingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 572protected abstract SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState); 574void ValidateOutgoingState(Message message) 586public override void VerifyIncomingMessage(ref Message message, TimeSpan timeout) 622public override SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout, params SecurityProtocolCorrelationState[] correlationStates) 659protected abstract SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates); 677Message message; 685public GetOneTokenAndSetUpSecurityAsyncResult(Message m, MessageSecurityProtocol binding, SecurityTokenProvider provider, 712internal static Message End(IAsyncResult result, out SecurityProtocolCorrelationState newCorrelationState) 733protected abstract void OnGetTokenDone(ref Message message, SecurityToken token, TimeSpan timeout); 799Message message; 809public GetTwoTokensAndSetUpSecurityAsyncResult(Message m, MessageSecurityProtocol binding, 840internal static Message End(IAsyncResult result, out SecurityProtocolCorrelationState newCorrelationState) 898protected abstract void OnBothGetTokenCallsDone(ref Message message, SecurityToken primaryToken, SecurityToken secondaryToken, TimeSpan timeout);
System\ServiceModel\Security\NegotiationTokenAuthenticator.cs (18)
562protected abstract BodyWriter ProcessRequestSecurityToken(Message request, RequestSecurityToken requestSecurityToken, out T negotiationState); 563protected abstract BodyWriter ProcessRequestSecurityTokenResponse(T negotiationState, Message request, RequestSecurityTokenResponse requestSecurityTokenResponse); 566protected virtual void ParseMessageBody(Message message, out string context, out RequestSecurityToken requestSecurityToken, out RequestSecurityTokenResponse requestSecurityTokenResponse) 596static Message CreateReply(Message request, XmlDictionaryString action, BodyWriter body) 600Message reply = Message.CreateMessage(request.Version, ActionHeader.Create(action, request.Version.Addressing), body); 607return Message.CreateMessage(request.Version, ActionHeader.Create(action, request.Version.Addressing), body); 713Message ProcessRequestCore(Message request) 900Message HandleNegotiationException(Message request, Exception e) 910Message CreateFault(Message request, Exception e) 945Message faultReply = Message.CreateMessage(version, fault, version.Addressing.DefaultFaultAction); 1035Message request = (Message)inputs[0];
System\ServiceModel\Security\ReceiveMessageAndVerifySecurityAsyncResultBase.cs (3)
14Message message; 89protected abstract bool OnInnerReceiveDone(ref Message message, TimeSpan timeout); 91public static bool End(IAsyncResult result, out Message message)
System\ServiceModel\Security\ReceiveSecurityHeader.cs (2)
115protected ReceiveSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay, 389public Message ProcessedMessage
System\ServiceModel\Security\RequestSecurityToken.cs (2)
43Message message; 175public Message Message
System\ServiceModel\Security\SecurityAppliedMessage.cs (1)
36public SecurityAppliedMessage(Message messageToProcess, SendSecurityHeader securityHeader, bool signBody, bool encryptBody)
System\ServiceModel\Security\SecurityChannel.cs (3)
109protected void ThrowIfDisposedOrNotOpen(Message message) 133public OutputChannelSendAsyncResult(Message message, SecurityProtocol binding, IOutputChannel channel, TimeSpan timeout, 140protected override IAsyncResult BeginSendCore(IOutputChannel channel, Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Security\SecurityHeader.cs (3)
21Message message; 31public SecurityHeader(Message message, 102protected Message Message
System\ServiceModel\Security\SecurityMessageProperty.cs (1)
208public static SecurityMessageProperty GetOrCreate(Message message)
System\ServiceModel\Security\SecurityProtocol.cs (33)
494static void SetSecurityHeaderId(SendSecurityHeader securityHeader, Message message) 523protected SendSecurityHeader CreateSendSecurityHeader(Message message, string actor, SecurityProtocolFactory factory) 528protected SendSecurityHeader CreateSendSecurityHeaderForTransportProtocol(Message message, string actor, SecurityProtocolFactory factory) 533SendSecurityHeader CreateSendSecurityHeader(Message message, string actor, SecurityProtocolFactory factory, bool requireMessageProtection) 552internal void AddMessageSupportingTokens(Message message, ref IList<SupportingTokenSpecification> supportingTokens) 573internal bool TryGetSupportingTokens(SecurityProtocolFactory factory, EndpointAddress target, Uri via, Message message, TimeSpan timeout, bool isBlockingCall, out IList<SupportingTokenSpecification> supportingTokens) 620protected IList<SupportingTokenAuthenticatorSpecification> GetSupportingTokenAuthenticatorsAndSetExpectationFlags(SecurityProtocolFactory factory, Message message, 705public virtual IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state) 708return new CompletedAsyncResult<Message>(message, callback, state); 711public virtual IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state) 714return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state); 717public virtual IAsyncResult BeginVerifyIncomingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state) 720return new CompletedAsyncResult<Message>(message, callback, state); 723public virtual IAsyncResult BeginVerifyIncomingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates, AsyncCallback callback, object state) 726return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state); 729public virtual void EndSecureOutgoingMessage(IAsyncResult result, out Message message) 731message = CompletedAsyncResult<Message>.End(result); 734public virtual void EndSecureOutgoingMessage(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState) 736message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState); 739public virtual void EndVerifyIncomingMessage(IAsyncResult result, out Message message) 741message = CompletedAsyncResult<Message>.End(result); 744public virtual void EndVerifyIncomingMessage(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState) 746message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState); 776public abstract void SecureOutgoingMessage(ref Message message, TimeSpan timeout); 779public virtual SecurityProtocolCorrelationState SecureOutgoingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 785protected virtual void OnOutgoingMessageSecured(Message securedMessage) 790protected virtual void OnSecureOutgoingMessageFailure(Message message) 795public abstract void VerifyIncomingMessage(ref Message message, TimeSpan timeout); 798public virtual SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout, params SecurityProtocolCorrelationState[] correlationStates) 805protected virtual void OnIncomingMessageVerified(Message verifiedMessage) 817protected virtual void OnVerifyIncomingMessageFailure(Message message, Exception exception) 858Message message; 864public GetSupportingTokensAsyncResult(Message m, SecurityProtocol binding, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Security\SecuritySessionClientSettings.cs (74)
437Message closeResponse; 751Message PrepareCloseMessage() 762Message closeMessage = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseAction, this.MessageVersion.Addressing), rst); 817Message closeMessage = PrepareCloseMessage(); 836Message message = null; 859Message closeMessage = PrepareCloseMessage(); 882MessageFault GetProtocolFault(ref Message message, out bool isKeyRenewalFault, out bool isSessionAbortedFault) 890Message copy = buffer.CreateMessage(); 931void ProcessCloseResponse(Message response) 970void PrepareReply(Message request, Message reply) 991bool DoesSkiClauseMatchSigningToken(SecurityContextKeyIdentifierClause skiClause, Message request) 1000void ProcessCloseMessage(Message message) 1027Message response = null; 1029response = Message.CreateMessage(message.Version, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, message.Version.Addressing), rstr); 1035response = Message.CreateMessage(message.Version, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, message.Version.Addressing), rstrCollection); 1050protected Message ProcessIncomingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, out MessageFault protocolFault) 1113protected Message ProcessRequestContext(RequestContext requestContext, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 1120Message message = requestContext.RequestMessage; 1121Message unverifiedMessage = message; 1294protected IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state) 1300return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, correlationState, callback, state); 1308protected Message EndSecureOutgoingMessage(IAsyncResult result, out SecurityProtocolCorrelationState correlationState) 1310if (result is CompletedAsyncResult<Message, SecurityProtocolCorrelationState>) 1312return CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out correlationState); 1317Message message = KeyRenewalAsyncResult.End(result, out remainingTime); 1323protected SecurityProtocolCorrelationState SecureOutgoingMessage(ref Message message, TimeSpan timeout) 1334protected void VerifyIncomingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 1392protected Message EndReceiveInternal(IAsyncResult result) 1397protected Message ReceiveInternal(TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 1411Message message = ProcessRequestContext(requestContext, timeoutHelper.RemainingTime(), correlationState); 1848Message message; 1903public static Message End(IAsyncResult result) 2478Message message; 2482public KeyRenewalAsyncResult(Message message, ClientSecuritySessionChannel sessionChannel, TimeSpan timeout, AsyncCallback callback, object state) 2516public static Message End(IAsyncResult result, out TimeSpan remainingTime) 2527Message message; 2533protected SecureSendAsyncResultBase(Message message, ClientSecuritySessionChannel sessionChannel, TimeSpan timeout, AsyncCallback callback, object state) 2572protected Message Message 2628public SecureSendAsyncResult(Message message, ClientSecuritySessionChannel sessionChannel, TimeSpan timeout, AsyncCallback callback, object state, bool autoCloseMessage) 2852Message message = ReceiveInternal(timeoutHelper.RemainingTime(), correlationState); 2887public Message Request(Message message) 2892Message ProcessReply(Message reply, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 2898Message unverifiedReply = reply; 2899Message processedReply = null; 2934public Message Request(Message message, TimeSpan timeout) 2940Message reply = this.ChannelBinder.Request(message, timeoutHelper.RemainingTime()); 2944public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 2949public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 2956public Message EndRequest(IAsyncResult result) 2960Message reply = SecureRequestAsyncResult.EndAsReply(result, out requestCorrelationState, out remainingTime); 2967Message reply; 2969public SecureRequestAsyncResult(Message request, ClientSecuritySessionChannel sessionChannel, TimeSpan timeout, AsyncCallback callback, object state) 3019public static Message EndAsReply(IAsyncResult result, out SecurityProtocolCorrelationState correlationState, out TimeSpan remainingTime) 3092Message message = this.requestChannel.EndReceiveInternal(result); 3107Message message = thisAsyncResult.requestChannel.EndReceiveInternal(result); 3127bool OnMessageReceived(Message message) 3151InputQueue<Message> queue; 3159this.queue = TraceUtility.CreateInputQueue<Message>(); 3190public Message Receive() 3195public Message Receive(TimeSpan timeout) 3210public Message EndReceive(IAsyncResult result) 3221public bool EndTryReceive(IAsyncResult result, out Message message) 3238public bool TryReceive(TimeSpan timeout, out Message message) 3250public void Send(Message message) 3255public void Send(Message message, TimeSpan timeout) 3264public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 3269public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 3341Message message = null;
System\ServiceModel\Security\SecuritySessionFilter.cs (13)
47static bool ShouldExcludeMessage(Message message, string[] excludedActions) 75public override bool Match(Message message) 122using (Message message = buffer.CreateMessage()) 294bool TryGetContextIds(Message message, out List<UniqueId> contextIds) 310bool TryMatchCore(Message message, out KeyValuePair<MessageFilter, FilterData> match) 343public bool GetMatchingValue(Message message, out FilterData data) 357using (Message message = buffer.CreateMessage()) 363public bool GetMatchingValues(Message message, ICollection<FilterData> results) 376using (Message message = buffer.CreateMessage()) 382public bool GetMatchingFilter(Message message, out MessageFilter filter) 396using (Message message = buffer.CreateMessage()) 402public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results) 415using (Message message = buffer.CreateMessage())
System\ServiceModel\Security\SecuritySessionSecurityTokenAuthenticator.cs (23)
434Message HandleOperationException(SecuritySessionOperation operation, Message request, Exception e) 440Message CreateFault(Message request, Exception e) 475Message faultReply = Message.CreateMessage(request.Version, fault, request.Version.Addressing.DefaultFaultAction); 658SecurityContextSecurityToken IssueToken(RequestSecurityToken rst, Message request, SecurityContextSecurityToken currentToken, ReadOnlyCollection<IAuthorizationPolicy> currentTokenPolicies, out RequestSecurityTokenResponse rstr) 762protected virtual Message ProcessRenewRequest(Message request) 807Message response = CreateReply(request, this.RenewResponseAction, replyMessage); 875protected virtual Message ProcessIssueRequest(Message request) 951Message response = CreateReply(request, this.IssueResponseAction, replyMessage); 964internal static bool DoesSkiClauseMatchSigningToken(SecurityContextKeyIdentifierClause skiClause, Message request) 994static Message CreateReply(Message request, XmlDictionaryString action, BodyWriter body) 998Message reply = Message.CreateMessage(request.Version, ActionHeader.Create(action, request.Version.Addressing), body); 1005return Message.CreateMessage(request.Version, ActionHeader.Create(action, request.Version.Addressing), body); 1009Message ProcessRequest(Message request) 1234return parent.ProcessRequest((Message)inputs[0]); 1340public override bool Match(Message message)
System\ServiceModel\Security\SecuritySessionSecurityTokenProvider.cs (20)
525Message CreateRequest(SecuritySessionOperation operation, EndpointAddress target, SecurityToken currentToken, out object requestState) 541GenericXmlSecurityToken ProcessReply(Message reply, SecuritySessionOperation operation, object requestState) 591using (Message requestMessage = this.CreateRequest(operation, target, currentToken, out requestState)) 601using (Message reply = channel.Request(requestMessage, timeoutHelper.RemainingTime())) 664void PrepareRequest(Message message) 701protected virtual Message CreateIssueRequest(EndpointAddress target, out object requestState) 707Message result = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.IssueAction, this.MessageVersion.Addressing), rst); 712GenericXmlSecurityToken ExtractToken(Message response, object requestState) 761protected virtual GenericXmlSecurityToken ProcessIssueResponse(Message response, object requestState) 767protected virtual Message CreateRenewRequest(EndpointAddress target, SecurityToken currentSessionToken, out object requestState) 774Message result = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.RenewAction, this.MessageVersion.Addressing), rst); 782protected virtual GenericXmlSecurityToken ProcessRenewResponse(Message response, object requestState) 792static protected void ThrowIfFault(Message message, EndpointAddress target) 924Message requestMessage = this.requestor.CreateRequest(this.operation, this.target, this.currentToken, out requestState); 946Message reply = this.channel.EndRequest(result); 972Message reply = this.channel.EndRequest(result); 1001bool OnReplyReceived(Message reply, object requestState) 1079public Message Message;
System\ServiceModel\Security\SecuritySessionServerSettings.cs (92)
1025Message message = requestContext.RequestMessage; 1328protected abstract void OnCloseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout); 1330protected abstract void OnCloseResponseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout); 1388bool CheckIncomingToken(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 1558Message message = innerRequestContext.RequestMessage; 1572Message requestMessage = ProcessRequestContext(innerRequestContext, timeoutHelper.RemainingTime(), out correlationState, out isSecurityProcessingFailure); 1589public Message Receive() 1594public Message Receive(TimeSpan timeout) 1596Message message; 1617public Message EndReceive(IAsyncResult result) 1619Message message; 1635public bool EndTryReceive(IAsyncResult result, out Message message) 1640public bool TryReceive(TimeSpan timeout, out Message message) 1688void SendFaultIfRequired(Exception e, Message unverifiedMessage, RequestContext requestContext, TimeSpan timeout) 1706using (Message faultMessage = Message.CreateMessage(unverifiedMessage.Version, fault, unverifiedMessage.Version.Addressing.DefaultFaultAction)) 1739Message ProcessRequestContext(RequestContext requestContext, TimeSpan timeout, out SecurityProtocolCorrelationState correlationState, out bool isSecurityProcessingFailure) 1748Message result = null; 1749Message message = requestContext.RequestMessage; 1754Message unverifiedMessage = message; 1832internal void SecureApplicationMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 1840internal SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout) 1845void PrepareReply(Message request, Message reply) 1888Message message = requestContext.RequestMessage; 1893Message response; 1896response = Message.CreateMessage(message.Version, renewFault, DotNetSecurityStrings.SecuritySessionFaultAction); 1901response = Message.CreateMessage(message.Version, renewFault, DotNetSecurityStrings.SecuritySessionFaultAction); 1927Message ProcessCloseRequest(Message request) 1961Message response = Message.CreateMessage(request.Version, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, request.Version.Addressing), bodyWriter); 1966internal Message CreateCloseResponse(Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 1970Message response = this.ProcessCloseRequest(message); 1998protected void SendCloseResponse(RequestContext requestContext, Message closeResponse, TimeSpan timeout) 2020internal IAsyncResult BeginSendCloseResponse(RequestContext requestContext, Message closeResponse, TimeSpan timeout, AsyncCallback callback, object state) 2060internal Message CreateCloseMessage(TimeSpan timeout) 2066Message closeMessage = Message.CreateMessage(this.messageVersion, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseAction, this.messageVersion.Addressing), rst); 2098using (Message closeMessage = CreateCloseMessage(timeoutHelper.RemainingTime())) 2119Message closeMessage = CreateCloseMessage(timeoutHelper.RemainingTime()); 2154protected void SendMessage(RequestContext requestContext, Message message, TimeSpan timeout) 2168internal IAsyncResult BeginSendMessage(RequestContext requestContext, Message response, TimeSpan timeout, AsyncCallback callback, object state) 2184Message message; 2186public SendMessageAsyncResult(ServerSecuritySessionChannel sessionChannel, RequestContext requestContext, Message message, TimeSpan timeout, AsyncCallback callback, 2217IAsyncResult BeginSend(Message response) 2552Message requestMessage; 2762public static bool EndAsMessage(IAsyncResult result, out Message message) 2840Message closeResponse; 2912bool ShouldSendCloseResponseOnClose(out RequestContext pendingCloseRequestContext, out Message pendingCloseResponse) 2941Message pendingCloseResponse; 3009Message pendingCloseResponse; 3021Message message; 3050protected override void OnCloseResponseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 3058protected override void OnCloseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 3072bool SendCloseResponseOnCloseReceivedIfRequired(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 3080Message localCloseResponse = null; 3137Message closeResponse; 3139public CloseAsyncResult(ServerSecuritySimplexSessionChannel sessionChannel, bool sendCloseResponse, RequestContext closeRequestContext, Message closeResponse, TimeSpan timeout, AsyncCallback callback, object state) 3265Message message = null; 3310Message message = null; 3355bool OnMessageReceived(Message message) 3535public SecuritySessionRequestContext(RequestContext requestContext, Message requestMessage, SecurityProtocolCorrelationState correlationState, ServerSecuritySessionChannel channel) 3553protected override void OnReply(Message message, TimeSpan timeout) 3563protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 3587Message closeResponseMessage; 3625public void Send(Message message) 3630public void Send(Message message, TimeSpan timeout) 3638public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 3643public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 3791Message message; 3838protected override void OnCloseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 3889protected override void OnCloseResponseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout) 3928void DetermineCloseOutputSessionMessage(out bool sendClose, out bool sendCloseResponse, out Message pendingCloseResponseMessage, out RequestContext pendingCloseRequestContext) 3964Message pendingCloseResponseMessage; 4037Message closeResponseMessage; 4228Message message = null; 4273Message message = null; 4318bool OnMessageReceived(Message message) 4695public void HandleDemuxFailure(Message message) 4707public Message CreateSessionDemuxFaultMessage(Message message) 4710Message faultMessage = Message.CreateMessage(message.Version, fault, message.Version.Addressing.DefaultFaultAction); 4718IAsyncResult BeginHandleDemuxFailure<TFaultContext>(Message message, TFaultContext faultContext, AsyncCallback callback, object state) 4721Message fault = CreateSessionDemuxFaultMessage(message); 4725public IAsyncResult BeginHandleDemuxFailure(Message message, RequestContext faultContext, AsyncCallback callback, object state) 4730public IAsyncResult BeginHandleDemuxFailure(Message message, IOutputChannel faultContext, AsyncCallback callback, object state) 4753Message message; 4757public SendFaultAsyncResult(Message fault, TFaultContext faultContext, AsyncCallback callback, object state) 4771IAsyncResult BeginSend(Message message)
System\ServiceModel\Security\SecurityStandardsManager.cs (5)
155internal SendSecurityHeader CreateSendSecurityHeader(Message message, 162internal ReceiveSecurityHeader CreateReceiveSecurityHeader(Message message, 179internal ReceiveSecurityHeader TryCreateReceiveSecurityHeader(Message message, 186internal bool DoesMessageContainSecurityHeader(Message message) 191internal bool TryGetSecurityContextIds(Message message, string[] actors, bool isStrictMode, ICollection<UniqueId> results)
System\ServiceModel\Security\SecurityUtils.cs (5)
295public static ChannelBinding GetChannelBindingFromMessage(Message message) 583internal static void EnsureExpectedSymmetricMatch(SecurityToken t1, SecurityToken t2, Message message) 1254internal static void ThrowIfNegotiationFault(Message message, EndpointAddress target) 1292internal static Exception CreateSecurityFaultException(Message unverifiedMessage) 1784internal static void MatchRstWithEndpointFilter(Message rst, IMessageFilterTable<EndpointAddress> endpointFilterTable, Uri listenUri)
System\ServiceModel\Security\SecurityVerifiedMessage.cs (2)
33public SecurityVerifiedMessage(Message messageToProcess, ReceiveSecurityHeader securityHeader) 164if (Message.ReadStartBody(reader, this.InnerMessage.Version.Envelope, out this.isDecryptedBodyFault, out this.isDecryptedBodyEmpty))
System\ServiceModel\Security\SecurityVersion.cs (9)
85internal abstract ReceiveSecurityHeader CreateReceiveSecurityHeader(Message message, 92internal abstract SendSecurityHeader CreateSendSecurityHeader(Message message, 98internal bool DoesMessageContainSecurityHeader(Message message) 103internal int FindIndexOfSecurityHeader(Message message, string[] actors) 122internal ReceiveSecurityHeader TryCreateReceiveSecurityHeader(Message message, 184internal override SendSecurityHeader CreateSendSecurityHeader(Message message, 193internal override ReceiveSecurityHeader CreateReceiveSecurityHeader(Message message, 232internal override ReceiveSecurityHeader CreateReceiveSecurityHeader(Message message, 246internal override SendSecurityHeader CreateSendSecurityHeader(Message message,
System\ServiceModel\Security\SendSecurityHeader.cs (2)
60protected SendSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay, 741public Message SetupExecution()
System\ServiceModel\Security\SspiNegotiationTokenAuthenticator.cs (4)
180protected override BodyWriter ProcessRequestSecurityToken(Message request, RequestSecurityToken requestSecurityToken, out SspiNegotiationTokenAuthenticatorState negotiationState) 231protected override BodyWriter ProcessRequestSecurityTokenResponse(SspiNegotiationTokenAuthenticatorState negotiationState, Message request, RequestSecurityTokenResponse requestSecurityTokenResponse) 251BodyWriter ProcessNegotiation(SspiNegotiationTokenAuthenticatorState negotiationState, Message incomingMessage, BinaryNegotiation incomingNego) 392public override bool Match(Message message)
System\ServiceModel\Security\SspiNegotiationTokenProvider.cs (1)
248protected override BodyWriter GetNextOutgoingMessageBody(Message incomingMessage, SspiNegotiationTokenProviderState sspiState)
System\ServiceModel\Security\SymmetricSecurityProtocol.cs (13)
156protected override IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state) 167return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state); 181protected override SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState) 193void SetUpDelayedSecurityExecution(ref Message message, 226protected override void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState) 228if (result is CompletedAsyncResult<Message, SecurityProtocolCorrelationState>) 230message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState); 253Message message, 285bool TryGetTokenSynchronouslyForOutgoingSecurity(Message message, SecurityProtocolCorrelationState correlationState, bool isBlockingCall, TimeSpan timeout, out SecurityToken token, out SecurityTokenParameters tokenParameters, out SecurityToken prerequisiteWrappingToken, out IList<SupportingTokenSpecification> supportingTokens, out SecurityProtocolCorrelationState newCorrelationState) 323void EnsureWrappedToken(SecurityToken token, Message message) 331protected override SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates) 401public SecureOutgoingMessageAsyncResult(Message m, SymmetricSecurityProtocol binding, SecurityTokenProvider provider, 409protected override void OnGetTokenDone(ref Message message, SecurityToken providerToken, TimeSpan timeout)
System\ServiceModel\Security\Tokens\IssuedSecurityTokenProvider.cs (1)
952protected override BodyWriter GetNextOutgoingMessageBody(Message incomingMessage, FederatedTokenProviderState negotiationState)
System\ServiceModel\Security\TransportSecurityProtocol.cs (22)
24public override void SecureOutgoingMessage(ref Message message, TimeSpan timeout) 51protected virtual void SecureOutgoingMessageAtInitiator(ref Message message, string actor, TimeSpan timeout) 58protected void SecureOutgoingMessageAtResponder(ref Message message, string actor) 67internal void SetUpDelayedSecurityExecution(ref Message message, string actor, 75public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state) 92return new CompletedAsyncResult<Message>(message, callback, state); 105public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state) 110protected virtual IAsyncResult BeginSecureOutgoingMessageAtInitiatorCore(Message message, string actor, TimeSpan timeout, AsyncCallback callback, object state) 117return new CompletedAsyncResult<Message>(message, callback, state); 125protected virtual Message EndSecureOutgoingMessageAtInitiatorCore(IAsyncResult result) 127if (result is CompletedAsyncResult<Message>) 129return CompletedAsyncResult<Message>.End(result); 137public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message) 143public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState) 152if (result is CompletedAsyncResult<Message>) 154message = CompletedAsyncResult<Message>.End(result); 172public sealed override void VerifyIncomingMessage(ref Message message, TimeSpan timeout) 198protected void AttachRecipientSecurityProperty(Message message, IList<SecurityToken> basicTokens, IList<SecurityToken> endorsingTokens, 206protected virtual void VerifyIncomingMessageCore(ref Message message, TimeSpan timeout) 275Message message; 279public SecureOutgoingMessageAsyncResult(string actor, Message message, TransportSecurityProtocol binding, TimeSpan timeout, AsyncCallback callback, object state) 294internal static Message End(IAsyncResult result)
System\ServiceModel\Security\WSSecurityOneDotOneReceiveSecurityHeader.cs (1)
17public WSSecurityOneDotOneReceiveSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay,
System\ServiceModel\Security\WSSecurityOneDotOneSendSecurityHeader.cs (1)
23public WSSecurityOneDotOneSendSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay,
System\ServiceModel\Security\WSSecurityOneDotZeroReceiveSecurityHeader.cs (1)
34public WSSecurityOneDotZeroReceiveSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay,
System\ServiceModel\Security\WSSecurityOneDotZeroSendSecurityHeader.cs (1)
47public WSSecurityOneDotZeroSendSecurityHeader(Message message, string actor, bool mustUnderstand, bool relay,
System\ServiceModel\Security\WSTrustChannel.cs (53)
37Message _response; 44Message request, 85public Message Response 97public new static Message End(IAsyncResult iar) 127Message EndOperation(IAsyncResult iar) 171/// The <see cref="IChannel" /> this class uses for sending and receiving <see cref="Message" /> objects. 202/// <see cref="Message" /> objects. 217/// The version of WS-Trust this channel will use for serializing <see cref="Message" /> objects. 286/// <see cref="Message" /> objects. 289/// The version of WS-Trust this channel will use for serializing <see cref="Message" /> objects. 364/// Creates a <see cref="Message"/> object that represents a WS-Trust RST message. 369/// <returns>The <see cref="Message" /> object that represents the WS-Trust message.</returns> 370protected virtual Message CreateRequest(System.IdentityModel.Protocols.WSTrust.RequestSecurityToken request, string requestType) 372return Message.CreateMessage(_messageVersion, 380/// Deserializes a <see cref="System.IdentityModel.Protocols.WSTrust.RequestSecurityTokenResponse" /> from a <see cref="Message" /> 383/// <param name="response">The <see cref="Message" /> received from the WS-Trust endpoint.</param> 387protected virtual System.IdentityModel.Protocols.WSTrust.RequestSecurityTokenResponse ReadResponse(Message response) 990Message request = CreateRequest(rst, RequestTypes.Issue); 992Message response = Contract.Issue(request); 1031Message request = this.CreateRequest(rst, requestType); 1051Message response = WSTrustChannelAsyncResult.End(result); 1171/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param> 1172/// <returns>The <see cref="Message" /> returned from the STS.</returns> 1173public Message Cancel(Message message) 1181/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param> 1191public IAsyncResult BeginCancel(Message message, AsyncCallback callback, object asyncState) 1200/// <returns>The <see cref="Message" /> returned from the STS.</returns> 1201public Message EndCancel(IAsyncResult asyncResult) 1209/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS</param> 1210/// <returns>The <see cref="Message" /> returned from the STS</returns> 1211public Message Issue(Message message) 1219/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param> 1229public IAsyncResult BeginIssue(Message message, AsyncCallback callback, object asyncState) 1238/// <returns>The <see cref="Message" /> returned from the STS.</returns> 1239public Message EndIssue(IAsyncResult asyncResult) 1247/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS</param> 1248/// <returns>The <see cref="Message" /> returned from the STS</returns> 1249public Message Renew(Message message) 1257/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param> 1267public IAsyncResult BeginRenew(Message message, AsyncCallback callback, object asyncState) 1276/// <returns>The <see cref="Message" /> returned from the STS.</returns> 1277public Message EndRenew(IAsyncResult asyncResult) 1285/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS</param> 1286/// <returns>The <see cref="Message" /> returned from the STS</returns> 1287public Message Validate(Message message) 1295/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param> 1305public IAsyncResult BeginValidate(Message message, AsyncCallback callback, object asyncState) 1314/// <returns>The <see cref="Message" /> returned from the STS.</returns> 1315public Message EndValidate(IAsyncResult asyncResult)
System\ServiceModel\Security\WSTrustDec2005.cs (2)
184Message RequestToken(Message message);
System\ServiceModel\Security\WSTrustFeb2005.cs (2)
274Message RequestToken(Message message);
System\ServiceModel\Security\WSTrustServiceContract.cs (75)
28using Message = System.ServiceModel.Channels.Message; 259protected virtual Message ProcessCore(Message requestMessage, WSTrustRequestSerializer requestSerializer, WSTrustResponseSerializer responseSerializer, string requestAction, string responseAction, string trustNamespace) 291Message response = null; 323response = Message.CreateMessage(OperationContext.Current.RequestContext.RequestMessage.Version, 352protected virtual DispatchContext CreateDispatchContext(Message requestMessage, 524protected virtual IAsyncResult BeginProcessCore(Message requestMessage, WSTrustRequestSerializer requestSerializer, WSTrustResponseSerializer responseSerializer, string requestAction, string responseAction, string trustNamespace, AsyncCallback callback, object state) 611protected virtual Message EndProcessCore(IAsyncResult ar, string requestAction, string responseAction, string trustNamespace) 624Message message = null; 704public Message ProcessTrust13Cancel(Message message) 714public Message ProcessTrust13Issue(Message message) 724public Message ProcessTrust13Renew(Message message) 734public Message ProcessTrust13Validate(Message message) 744public Message ProcessTrust13CancelResponse(Message message) 759public Message ProcessTrust13IssueResponse(Message message) 774public Message ProcessTrust13RenewResponse(Message message) 789public Message ProcessTrust13ValidateResponse(Message message) 804public Message ProcessTrustFeb2005Cancel(Message message) 814public Message ProcessTrustFeb2005Issue(Message message) 824public Message ProcessTrustFeb2005Renew(Message message) 834public Message ProcessTrustFeb2005Validate(Message message) 844public Message ProcessTrustFeb2005CancelResponse(Message message) 859public Message ProcessTrustFeb2005IssueResponse(Message message) 874public Message ProcessTrustFeb2005RenewResponse(Message message) 889public Message ProcessTrustFeb2005ValidateResponse(Message message) 921public IAsyncResult BeginTrust13Cancel(Message request, AsyncCallback callback, object state) 931public Message EndTrust13Cancel(IAsyncResult ar) 943public IAsyncResult BeginTrust13Issue(Message request, AsyncCallback callback, object state) 953public Message EndTrust13Issue(IAsyncResult ar) 965public IAsyncResult BeginTrust13Renew(Message request, AsyncCallback callback, object state) 975public Message EndTrust13Renew(IAsyncResult ar) 987public IAsyncResult BeginTrust13Validate(Message request, AsyncCallback callback, object state) 997public Message EndTrust13Validate(IAsyncResult ar) 1009public IAsyncResult BeginTrust13CancelResponse(Message request, AsyncCallback callback, object state) 1026public Message EndTrust13CancelResponse(IAsyncResult ar) 1041public IAsyncResult BeginTrust13IssueResponse(Message request, AsyncCallback callback, object state) 1058public Message EndTrust13IssueResponse(IAsyncResult ar) 1073public IAsyncResult BeginTrust13RenewResponse(Message request, AsyncCallback callback, object state) 1090public Message EndTrust13RenewResponse(IAsyncResult ar) 1105public IAsyncResult BeginTrust13ValidateResponse(Message request, AsyncCallback callback, object state) 1122public Message EndTrust13ValidateResponse(IAsyncResult ar) 1137public IAsyncResult BeginTrustFeb2005Cancel(Message request, AsyncCallback callback, object state) 1147public Message EndTrustFeb2005Cancel(IAsyncResult ar) 1159public IAsyncResult BeginTrustFeb2005Issue(Message request, AsyncCallback callback, object state) 1169public Message EndTrustFeb2005Issue(IAsyncResult ar) 1181public IAsyncResult BeginTrustFeb2005Renew(Message request, AsyncCallback callback, object state) 1191public Message EndTrustFeb2005Renew(IAsyncResult ar) 1203public IAsyncResult BeginTrustFeb2005Validate(Message request, AsyncCallback callback, object state) 1213public Message EndTrustFeb2005Validate(IAsyncResult ar) 1225public IAsyncResult BeginTrustFeb2005CancelResponse(Message request, AsyncCallback callback, object state) 1242public Message EndTrustFeb2005CancelResponse(IAsyncResult ar) 1257public IAsyncResult BeginTrustFeb2005IssueResponse(Message request, AsyncCallback callback, object state) 1274public Message EndTrustFeb2005IssueResponse(IAsyncResult ar) 1289public IAsyncResult BeginTrustFeb2005RenewResponse(Message request, AsyncCallback callback, object state) 1306public Message EndTrustFeb2005RenewResponse(IAsyncResult ar) 1321public IAsyncResult BeginTrustFeb2005ValidateResponse(Message request, AsyncCallback callback, object state) 1338public Message EndTrustFeb2005ValidateResponse(IAsyncResult ar) 1425public new static Message End(IAsyncResult ar) 1438return Message.CreateMessage(OperationContext.Current.RequestContext.RequestMessage.Version,
System\ServiceModel\ServiceAuthenticationManager.cs (4)
18public virtual ReadOnlyCollection<IAuthorizationPolicy> Authenticate(ReadOnlyCollection<IAuthorizationPolicy> authPolicy, Uri listenUri, ref Message message) 38public override ReadOnlyCollection<IAuthorizationPolicy> Authenticate(ReadOnlyCollection<IAuthorizationPolicy> authPolicy, Uri listenUri, ref Message message) 83public override ReadOnlyCollection<IAuthorizationPolicy> Authenticate(ReadOnlyCollection<IAuthorizationPolicy> authPolicy, Uri listenUri, ref Message message) 113bool CanSkipAuthentication(Message message)
System\ServiceModel\ServiceAuthorizationManager.cs (1)
25public virtual bool CheckAccess(OperationContext operationContext, ref Message message)
System\ServiceModel\ServiceHost.cs (1)
1127internal void RaiseUnknownMessageReceived(Message message)
System\ServiceModel\Transactions\OletxTransactionFormatter.cs (2)
21public override void WriteTransaction(Transaction transaction, Message message) 37public override TransactionInfo ReadTransaction(Message message)
System\ServiceModel\Transactions\OletxTransactionHeader.cs (1)
77public static OleTxTransactionHeader ReadFrom(Message message)
System\ServiceModel\Transactions\TransactionFormatter.cs (2)
71public abstract void WriteTransaction(Transaction transaction, Message message); 78public abstract TransactionInfo ReadTransaction(Message message);
System\ServiceModel\Transactions\WsatRegistrationHeader.cs (1)
94public static WsatRegistrationHeader ReadFrom(Message message)
System\ServiceModel\Transactions\WsatTransactionFormatter.cs (2)
51public override void WriteTransaction(Transaction transaction, Message message) 89public override TransactionInfo ReadTransaction(Message message)
System\ServiceModel\Transactions\WsatTransactionHeader.cs (1)
62public static CoordinationContext GetCoordinationContext(Message message, ProtocolVersion protocolVersion)
System\ServiceModel\UnknownMessageReceivedEventArgs.cs (3)
12Message message; 14internal UnknownMessageReceivedEventArgs(Message message) 19public Message Message
System\ServiceModel\XPathMessageQuery.cs (1)
95public override TResult Evaluate<TResult>(Message message)
System.ServiceModel.Activation (9)
System\ServiceModel\Activation\HostedAspNetEnvironment.cs (3)
382public override IAspNetMessageProperty GetHostingProperty(Message message) 387public override IAspNetMessageProperty GetHostingProperty(Message message, bool removeFromMessage) 404public override void PrepareMessageForDispatch(Message message)
System\ServiceModel\Activation\HostedHttpContext.cs (6)
158protected override void OnReply(Message message, TimeSpan timeout) 165Message message, TimeSpan timeout, AsyncCallback callback, object state) 192public override HttpOutput GetHttpOutput(Message message) 300protected override void AddProperties(Message message) 474Message message, HostedHttpContext context) 549protected override bool PrepareHttpSend(Message message)
System.ServiceModel.Activities (110)
System\ServiceModel\Activities\Constants.cs (1)
22public static readonly Type MessageType = typeof(Message);
System\ServiceModel\Activities\ContractValidationHelper.cs (9)
221else if (declaredMessageType != null && declaredMessageType.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 236else if (!targetMessage.Body.ReturnValue.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 253if (!targetMessage.Body.Parts[0].Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 502if (!messagePart.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 523|| (message.Body.ReturnValue != null && message.Body.ReturnValue.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message)))) 529if (operation.Messages[1].MessageType != null || operation.Messages[1].Body.ReturnValue.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 568if (!message.Body.ReturnValue.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 591if (!messagePart.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 613&& operation.Messages[0].Body.Parts[0].Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message)))
System\ServiceModel\Activities\CorrelationRequestContext.cs (3)
29public Message Reply 75public void ReceiveReply(OperationContext operationContext, Message reply) 82public void ReceiveAsyncReply(OperationContext operationContext, Message reply, Exception replyException)
System\ServiceModel\Activities\Dispatcher\CorrelationKeyCalculator.cs (12)
43public bool CalculateKeys(Message message, out InstanceKey instanceKey, 56public bool CalculateKeys(MessageBuffer buffer, Message messageToReadHeaders, out InstanceKey instanceKey, 78public bool CalculateKeys(T target, Message messageToReadHeaders, out InstanceKey instanceKey, 198protected abstract IEnumerable<KeyValuePair<MessageQuery, string>> ExecuteSelect(T target, Message messageToReadHeaders, 201protected abstract bool ExecuteWhere(T target, Message messageToReadHeaders, MessageFilterTable<SelectRuntime> whereRuntime, 225protected override IEnumerable<KeyValuePair<MessageQuery, string>> ExecuteSelect(MessageBuffer target, Message messageToReadHeaders, 239protected override bool ExecuteWhere(MessageBuffer target, Message messageToReadHeaders, MessageFilterTable<SelectRuntime> whereRuntime, 248class MessageCalculator : Calculator<Message> 257protected override IEnumerable<KeyValuePair<MessageQuery, string>> ExecuteSelect(Message target, Message messageToReadHeaders, 263protected override bool ExecuteWhere(Message target, Message messageToReadHeaders, MessageFilterTable<SelectRuntime> whereRuntime,
System\ServiceModel\Activities\Dispatcher\DurableInstanceContextProvider.cs (2)
21public InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel) 29public void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel)
System\ServiceModel\Activities\Dispatcher\DurableInstanceProvider.cs (1)
34public object GetInstance(InstanceContext instanceContext, Message message)
System\ServiceModel\Activities\Dispatcher\OptionalMessageQuery.cs (1)
27public override TResult Evaluate<TResult>(Message message)
System\ServiceModel\Activities\FromReply.cs (3)
19public InArgument<Message> Message 82Message inMessage = this.Message.Get(context); 134Exception DeserializeFault(Message inMessage, FaultConverter faultConverter)
System\ServiceModel\Activities\FromRequest.cs (2)
19public InOutArgument<Message> Message 79Message inMessage = null;
System\ServiceModel\Activities\InternalReceiveMessage.cs (6)
94public OutArgument<Message> Message 547Message request = instance.CorrelationResponseContext.WorkflowOperationContext.Inputs[0] as Message; 554instance.CorrelationResponseContext.MessageVersion = ((Message)instance.CorrelationResponseContext.WorkflowOperationContext.Inputs[0]).Version; 713Message request = instance.CorrelationRequestContext.Reply; 767this.Message = new OutArgument<Message>();
System\ServiceModel\Activities\InternalSendMessage.cs (22)
160internal OutArgument<Message> MessageOut 213public InArgument<Message> Message 580this.Message = new InArgument<Message>(); 757Message message = this.Message.Get(context); 1231Message message = InitializeCorrelations(context, instance); 1549Message InitializeCorrelations(NativeActivityContext context, SendMessageInstance instance) 1844Message reply = ((IRequestChannel)this.channel).EndRequest(result); 1908Message reply = null; 2122Action<Message> onWorkflowCorrelationProcessingComplete; 2137public Message UpdatedMessage 2143public void NotifyRequestSetByChannel(Action<Message> onWorkflowCorrelationProcessingComplete) 2162public void NotifyMessageUpdatedByWorkflow(Message message) 2388public Message RequestOrReply 2624protected override IAsyncResult OnBeginFinalizeCorrelation(Message message, TimeSpan timeout, AsyncCallback callback, object state) 2629protected override Message OnEndFinalizeCorrelation(IAsyncResult result) 2634protected override Message OnFinalizeCorrelation(Message message, TimeSpan timeout) 2641Message message; 2646public FinalizeCorrelationAsyncResult(MessageCorrelationCallbackMessageProperty property, Message message, 2664property.Instance.CorrelationSynchronizer.NotifyRequestSetByChannel(new Action<Message>(OnWorkflowCorrelationProcessingComplete)); 2695void OnWorkflowCorrelationProcessingComplete(Message updatedMessage) 2727public static Message End(IAsyncResult result)
System\ServiceModel\Activities\MessageContext.cs (3)
13Message message; 20internal MessageContext(Message message) 25public virtual Message Message
System\ServiceModel\Activities\MessagingActivityHelper.cs (2)
78public static Message InitializeCorrelationHandles(NativeActivityContext context, 80CorrelationKeyCalculator keyCalculator, Message message)
System\ServiceModel\Activities\Receive.cs (7)
60Variable<Message> request = new Variable<Message> { Name = "RequestMessage" }; 62this.internalReceive.Message = new OutArgument<Message>(request); 63this.requestFormatter.Message = new InOutArgument<Message>(request); 543if (!messagePart.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 600|| (message.Body.ReturnValue != null && message.Body.ReturnValue.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message)))) 606if (operation.Messages[1].MessageType != null || operation.Messages[1].Body.ReturnValue.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message)))
System\ServiceModel\Activities\ReceiveMessageContent.cs (4)
114internalReceiveMessage.Message = new OutArgument<Message>(context => ((OutArgument<Message>)this.Message).Get(context)); 132internalReceiveMessage.Message = new OutArgument<Message>(context => ((OutArgument<Message>)this.Message).Get(context));
System\ServiceModel\Activities\ReceiveReply.cs (4)
43Variable<Message> response = new Variable<Message> { Name = "ResponseMessage" }; 44this.internalReceive.Message = new OutArgument<Message>(response); 45this.responseFormatter.Message = new InArgument<Message>(response);
System\ServiceModel\Activities\Send.cs (5)
56Variable<Message> request = new Variable<Message> { Name = "RequestMessage" }; 57this.requestFormatter.Message = new OutArgument<Message>(request); 59this.internalSend.Message = new InArgument<Message>(request); 60this.internalSend.MessageOut = new OutArgument<Message>(request);
System\ServiceModel\Activities\SendMessageContent.cs (4)
130internalSendMessage.Message = new InArgument<Message>(context => ((InArgument<Message>)this.Message).Get(context)); 147internalSendMessage.Message = new InArgument<Message>(context => ((InArgument<Message>)this.Message).Get(context));
System\ServiceModel\Activities\SendReply.cs (8)
48Variable<Message> response = new Variable<Message> { Name = "ResponseMessage" }; 49this.responseFormatter.Message = new OutArgument<Message>(response); 50this.internalSend.Message = new InArgument<Message>(response); 53this.internalSend.MessageOut = new OutArgument<Message>(response); 290if (!message.Body.ReturnValue.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 313if (!messagePart.Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message))) 381&& operation.Messages[0].Body.Parts[0].Type.IsAssignableFrom(typeof(System.ServiceModel.Channels.Message)))
System\ServiceModel\Activities\ToReply.cs (5)
82public OutArgument<Message> Message 111this.Message = new OutArgument<Message>(); 228Message outMessage = System.ServiceModel.Channels.Message.CreateMessage(version, messageFault, action); 255Message outMessage = this.Formatter.SerializeReply(version, inObjects, returnValue);
System\ServiceModel\Activities\ToRequest.cs (2)
48public OutArgument<Message> Message 116Message outMessage = this.Formatter.SerializeRequest(this.MessageVersion, inObjects);
System\ServiceModel\Activities\WorkflowOperationContext.cs (3)
236public void SendReply(Message returnValue) 552Message faultMessage = returnValue as Message;
System\ServiceModel\CorrelationActionMessageFilter.cs (1)
38public override bool Match(Message message)
System.ServiceModel.Channels (88)
System\ServiceModel\Channels\ByteStreamMessage.cs (9)
16public static Message CreateMessage(Stream stream) 25public static Message CreateMessage(ArraySegment<byte> buffer) 30public static Message CreateMessage(ArraySegment<byte> buffer, BufferManager bufferManager) 41internal static Message CreateMessage(Stream stream, XmlDictionaryReaderQuotas quotas, bool moveBodyReaderToContent) 46internal static Message CreateMessage(HttpRequestMessage httpRequestMessage, XmlDictionaryReaderQuotas quotas) 51internal static Message CreateMessage(HttpResponseMessage httpResponseMessage, XmlDictionaryReaderQuotas quotas) 56internal static Message CreateMessage(ByteStreamBufferedMessageData bufferedMessageData, XmlDictionaryReaderQuotas quotas, bool moveBodyReaderToContent) 61internal static bool IsInternalByteStreamMessage(Message message) 712public override Message CreateMessage()
System\ServiceModel\Channels\ByteStreamMessageEncoder.cs (10)
66public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 78Message message = ByteStreamMessage.CreateMessage(stream, this.quotas, this.moveBodyReaderToContent); 94public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 113Message message = ByteStreamMessage.CreateMessage(messageData, this.bufferedReadReaderQuotas, this.moveBodyReaderToContent); 132public override void WriteMessage(Message message, Stream stream) 171public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state) 198public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 269public Stream GetResponseMessageStream(Message message) 300Message message; 306public WriteMessageAsyncResult(Message message, Stream stream, AsyncCallback callback, object state)
System\ServiceModel\Channels\ClientUdpOutputChannel.cs (2)
39protected override UdpSocket[] GetSendSockets(Message message, out IPEndPoint remoteEndPoint, out Exception exceptionToBeThrown) 59protected override void AddHeadersTo(Message message)
System\ServiceModel\Channels\HttpRequestMessageExtensionMethods.cs (8)
12/// A static extension methods class for getting a <see cref="Message"/> instance 18/// An extension method for getting a <see cref="Message"/> instance 22/// The <see cref="Message"/> instance can be read, written and copied 24/// <see cref="Message"/> instance can also "read" to retrieve the original 30/// from which to create the <see cref="Message"/> instance.</param> 31/// <returns>The new <see cref="Message"/> instance.</returns> 32public static Message ToMessage(this HttpRequestMessage httpRequestMessage) 39Message message = ByteStreamMessage.CreateMessage(httpRequestMessage, null);
System\ServiceModel\Channels\HttpResponseMessageExtensionMethods.cs (8)
12/// A static extension methods class for getting a <see cref="Message"/> instance 18/// An extension method for getting a <see cref="Message"/> instance 22/// The <see cref="Message"/> instance can be read, written and copied 24/// <see cref="Message"/> instance can also "read" to retrieve the original 30/// from which to create the <see cref="Message"/> instance.</param> 31/// <returns>The new <see cref="Message"/> instance.</returns> 32public static Message ToMessage(this HttpResponseMessage httpResponseMessage) 39Message message = ByteStreamMessage.CreateMessage(httpResponseMessage, null);
System\ServiceModel\Channels\MessageExtensionMethods.cs (13)
16/// or <see cref="HttpResponseMessage"/> instance from a <see cref="Message"/> instance. 28/// from an <see cref="Message"/> instance. 30/// <param name="message">The <see cref="Message"/> instance from which to 33public static HttpRequestMessage ToHttpRequestMessage(this Message message) 61/// from an <see cref="Message"/> instance. 63/// <param name="message">The <see cref="Message"/> instance from which to 66public static HttpResponseMessage ToHttpResponseMessage(this Message message) 92internal static void ConfigureAsHttpMessage(this Message message, HttpRequestMessage httpRequestMessage) 101internal static void ConfigureAsHttpMessage(this Message message, HttpResponseMessage httpResponseMessage) 114private static void CopyPropertiesToMessage(Message message, IDictionary<string, object> properties) 138private static HttpRequestMessage CreateRequestMessage(Message message, HttpRequestMessageProperty requestMessageProperty) 162private static HttpResponseMessage CreateResponseMessage(Message message, HttpResponseMessageProperty responseMessageProperty) 189private static HttpContent CreateMessageContent(Message message, bool suppressEntityBody)
System\ServiceModel\Channels\NetworkInterfaceMessageProperty.cs (2)
34public static bool TryGet(Message message, out NetworkInterfaceMessageProperty property) 63public void AddTo(Message message)
System\ServiceModel\Channels\ServerUdpOutputChannel.cs (1)
98protected override UdpSocket[] GetSendSockets(Message message, out IPEndPoint remoteEndPoint, out Exception exceptionToBeThrown)
System\ServiceModel\Channels\UdpChannelBase.cs (4)
144Message message = null; 242internal bool EnqueueMessage(Message message, int messageBufferSize, Action messageDequeuedCallback) 294internal abstract void FinishEnqueueMessage(Message message, Action dequeuedCallback, bool canDispatchOnThisThread); 296protected virtual void AddHeadersTo(Message message)
System\ServiceModel\Channels\UdpChannelFactory.cs (1)
370protected override void AddHeadersTo(Message message)
System\ServiceModel\Channels\UdpChannelListener.cs (3)
174Message message = null; 459bool Dispatch(Message message, int messageBufferSize, Action onMessageDequeuedCallback) 729internal class UdpDuplexChannelListener : UdpChannelListener<IDuplexChannel, UdpDuplexChannel, Message>
System\ServiceModel\Channels\UdpDuplexChannel.cs (11)
18abstract class UdpDuplexChannel : UdpChannelBase<Message>, IDuplexChannel 50public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 55public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 79public void Send(Message message) 84public void Send(Message message, TimeSpan timeout) 94public Message Receive() 99public Message Receive(TimeSpan timeout) 126public Message EndReceive(IAsyncResult result) 131public bool TryReceive(TimeSpan timeout, out Message message) 153public bool EndTryReceive(IAsyncResult result, out Message message) 185internal override void FinishEnqueueMessage(Message message, Action dequeuedCallback, bool canDispatchOnThisThread)
System\ServiceModel\Channels\UdpOutputChannel.cs (9)
141protected static void LogMessage(ref Message message, ArraySegment<byte> messageData) 149protected override void AddHeadersTo(Message message) 175protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 197protected override void OnSend(Message message, TimeSpan timeout) 290protected abstract UdpSocket[] GetSendSockets(Message message, out IPEndPoint remoteEndPoint, out Exception exceptionToBeThrown); 337protected ArraySegment<byte> EncodeMessage(Message message) 646private Message message; 649public SendAsyncResult(UdpOutputChannel channel, Message message, TimeSpan timeout, AsyncCallback callback, object state) 885private void Initialize(Message message)
System\ServiceModel\Channels\UdpReplyChannel.cs (1)
150internal override void FinishEnqueueMessage(Message message, Action dequeuedCallback, bool canDispatchOnThisThread)
System\ServiceModel\Channels\UdpRequestContext.cs (4)
19public UdpRequestContext(UdpOutputChannel outputChannel, Message requestMessage) 44protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state) 66protected override void OnReply(Message message, TimeSpan timeout) 75private void SetAddressingInformation(Message message)
System\ServiceModel\Channels\UdpUtility.cs (2)
535public static Message DecodeMessage(DuplicateMessageDetector duplicateDetector, MessageEncoder encoder, BufferManager bufferManager, ArraySegment<byte> data, IPEndPoint remoteEndPoint, int interfaceIndex, bool ignoreSerializationException, out string messageHash) 542Message message = null;
System.ServiceModel.Discovery (29)
System\ServiceModel\Discovery\DiscoveryClientDuplexChannel.cs (8)
35public override IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 41public override void Send(Message message, TimeSpan timeout) 67public Message EndReceive(IAsyncResult result) 72public bool EndTryReceive(IAsyncResult result, out Message message) 82public Message Receive(TimeSpan timeout) 87public Message Receive() 92public bool TryReceive(TimeSpan timeout, out Message message) 102void EnsureReplyTo(Message message)
System\ServiceModel\Discovery\DiscoveryClientOutputChannel.cs (4)
49public virtual IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 54public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 64public virtual void Send(Message message, TimeSpan timeout) 69public void Send(Message message)
System\ServiceModel\Discovery\DiscoveryClientRequestChannel.cs (7)
49public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 54public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 59public Message EndRequest(IAsyncResult result) 64public Message Request(Message message, TimeSpan timeout) 69public Message Request(Message message)
System\ServiceModel\Discovery\DiscoveryOperationContextExtensionInitializer.cs (2)
42object IDispatchMessageInspector.AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext) 48void IDispatchMessageInspector.BeforeSendReply(ref Message reply, object correlationState)
System\ServiceModel\Discovery\ServiceDiscoveryInstanceContextProvider.cs (3)
21InstanceContext IInstanceContextProvider.GetExistingInstanceContext(Message message, IContextChannel channel) 27void IInstanceContextProvider.InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel) 40object IInstanceProvider.GetInstance(InstanceContext instanceContext, Message message)
System\ServiceModel\Discovery\UdpDiscoveryMessageFilter.cs (1)
43public override bool Match(Message message)
System\ServiceModel\Discovery\UdpReplyToBehavior.cs (4)
78public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext) 122public void BeforeSendReply(ref Message reply, object correlationState) 126void IClientMessageInspector.AfterReceiveReply(ref Message reply, object correlationState) 130object IClientMessageInspector.BeforeSendRequest(ref Message request, IClientChannel channel)
System.ServiceModel.Routing (90)
System\ServiceModel\Channels\SynchronousSendBindingElement.cs (21)
179public Message EndReceive(IAsyncResult result) 184public bool EndTryReceive(IAsyncResult result, out Message message) 199public Message Receive(TimeSpan timeout) 204public Message Receive() 209public bool TryReceive(TimeSpan timeout, out Message message) 249public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) 255public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) 271public void Send(Message message, TimeSpan timeout) 276public void Send(Message message) 316public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 318Message reply = this.InnerChannel.Request(message, timeout); 319return new CompletedAsyncResult<Message>(reply, callback, state); 322public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 324Message reply = this.InnerChannel.Request(message); 325return new CompletedAsyncResult<Message>(reply, callback, state); 328public Message EndRequest(IAsyncResult result) 330return CompletedAsyncResult<Message>.End(result); 338public Message Request(Message message, TimeSpan timeout) 343public Message Request(Message message)
System\ServiceModel\Dispatcher\EndpointNameMessageFilter.cs (2)
33public override bool Match(Message message) 48using (Message tempMessage = buffer.CreateMessage())
System\ServiceModel\Dispatcher\StrictAndMessageFilter.cs (5)
35public override bool Match(Message message) 99public bool GetMatchingFilter(Message message, out MessageFilter filter) 124public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results) 160public bool GetMatchingValue(Message message, out TFilterData value) 196public bool GetMatchingValues(Message message, ICollection<TFilterData> results)
System\ServiceModel\Routing\ClientFactory.cs (18)
152public IAsyncResult BeginOperation(Message message, Transaction transaction, AsyncCallback callback, object state) 157public Message EndOperation(IAsyncResult result) 162protected abstract IAsyncResult OnBeginOperation(Message message, AsyncCallback callback, object state); 163protected abstract Message OnEndOperation(IAsyncResult asyncResult); 181Message replyMessage; 182Message requestMessage; 185public OperationAsyncResult(RoutingClientBase<TChannel> parent, Message requestMessage, Transaction transaction, AsyncCallback callback, object state) 240public static Message End(IAsyncResult result) 327protected override IAsyncResult OnBeginOperation(Message message, AsyncCallback callback, object state) 332protected override Message OnEndOperation(IAsyncResult result) 346protected override IAsyncResult OnBeginOperation(Message message, AsyncCallback callback, object state) 351protected override Message OnEndOperation(IAsyncResult result) 365protected override IAsyncResult OnBeginOperation(Message message, AsyncCallback callback, object state) 370protected override Message OnEndOperation(IAsyncResult result) 392IAsyncResult IDuplexRouterCallback.BeginProcessMessage(Message message, AsyncCallback callback, object state) 433public CallbackAsyncResult(IDuplexRouterCallback callbackInstance, Message message, AsyncCallback callback, object state) 473protected override IAsyncResult OnBeginOperation(Message message, AsyncCallback callback, object state) 478protected override Message OnEndOperation(IAsyncResult result)
System\ServiceModel\Routing\IDuplexRouterCallback.cs (1)
16IAsyncResult BeginProcessMessage(Message message, AsyncCallback callback, object state);
System\ServiceModel\Routing\IDuplexSessionRouter.cs (1)
16IAsyncResult BeginProcessMessage(Message message, AsyncCallback callback, object state);
System\ServiceModel\Routing\IRequestReplyRouter.cs (2)
16IAsyncResult BeginProcessRequest(Message message, AsyncCallback callback, object state); 18Message EndProcessRequest(IAsyncResult result);
System\ServiceModel\Routing\IRoutingClient.cs (2)
13IAsyncResult BeginOperation(Message message, Transaction transaction, AsyncCallback callback, object state); 14Message EndOperation(IAsyncResult result);
System\ServiceModel\Routing\ISimplexDatagramRouter.cs (1)
15IAsyncResult BeginProcessMessage(Message message, AsyncCallback callback, object state);
System\ServiceModel\Routing\ISimplexSessionRouter.cs (1)
15IAsyncResult BeginProcessMessage(Message message, AsyncCallback callback, object state);
System\ServiceModel\Routing\MessageRpc.cs (4)
31Message originalMessage; 32Message clonedMessage; 41public MessageRpc(Message message, OperationContext operationContext, bool impersonationRequired) 131public Message Message
System\ServiceModel\Routing\ProcessMessagesAsyncResult.cs (2)
35public ProcessMessagesAsyncResult(Message message, RoutingService service, TimeSpan timeout, AsyncCallback callback, object state) 174Message message;
System\ServiceModel\Routing\ProcessRequestAsyncResult.cs (5)
23Message replyMessage; 27public ProcessRequestAsyncResult(RoutingService service, Message message, AsyncCallback callback, object state) 74Message message; 174Message responseMsg = this.currentClient.EndOperation(result); 200internal static Message End(IAsyncResult result)
System\ServiceModel\Routing\RoutingService.cs (8)
226IAsyncResult ISimplexSessionRouter.BeginProcessMessage(Message message, AsyncCallback callback, object state) 237IAsyncResult IRequestReplyRouter.BeginProcessRequest(Message message, AsyncCallback callback, object state) 242Message IRequestReplyRouter.EndProcessRequest(IAsyncResult result) 248IAsyncResult IDuplexSessionRouter.BeginProcessMessage(Message message, AsyncCallback callback, object state) 259IAsyncResult ISimplexDatagramRouter.BeginProcessMessage(Message message, AsyncCallback callback, object state) 269IAsyncResult BeginProcessMessage<TContract>(Message message, AsyncCallback callback, object state) 303IAsyncResult BeginProcessRequest<TContract>(Message message, AsyncCallback callback, object state) 320Message EndProcessRequest<TContract>(IAsyncResult result)
System\ServiceModel\Routing\SendOperation.cs (1)
67public void PrepareMessage(Message message)
System\ServiceModel\Routing\SoapProcessingBehavior.cs (16)
101Message request = (Message)inputs[0]; 106void IClientMessageInspector.AfterReceiveReply(ref Message reply, object correlationState) 110Message originalMessage = (Message)correlationState; 142object IClientMessageInspector.BeforeSendRequest(ref Message request, IClientChannel channel) 144Message originalRequest = request; 153object IDispatchMessageInspector.AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext) 159void IDispatchMessageInspector.BeforeSendReply(ref Message reply, object correlationState) 177void PreProcess(Message message) 200internal Message MarshalMessage(Message source, Uri to, MessageVersion targetVersion) 202Message result; 242result = Message.CreateMessage(targetVersion, messageFault, action); 246result = Message.CreateMessage(targetVersion, sourceHeaders.Action); 251result = Message.CreateMessage(targetVersion, sourceHeaders.Action, bodyReader);
System.ServiceModel.Web (172)
System\ServiceModel\Channels\HttpStreamMessage.cs (1)
216public override Message CreateMessage()
System\ServiceModel\Channels\JsonMessageEncoderFactory.cs (7)
162public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 174Message message; 204public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 217Message message = Message.CreateMessage(reader, maxSizeOfHeaders, MessageVersion.None); 232public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 299public override void WriteMessage(Message message, Stream stream)
System\ServiceModel\Channels\WebMessageEncoderFactory.cs (10)
181public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 189Message message; 211public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 219Message message; 240public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 289public override void WriteMessage(Message message, Stream stream) 331public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state) 358WebContentFormat ExtractFormatFromMessage(Message message) 458Message message; 464public WriteMessageAsyncResult(Message message, Stream stream, WebMessageEncoder webMessageEncoder, AsyncCallback callback, object state)
System\ServiceModel\Channels\WebScriptMetadataMessageEncoderFactory.cs (4)
70public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 75public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 80public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 116public override void WriteMessage(Message message, Stream stream)
System\ServiceModel\Description\WCFServiceClientProxyGenerator.cs (1)
91return (typeof(Message).IsAssignableFrom(t)) ? typeof(object) : t;
System\ServiceModel\Description\WebHttpBehavior.cs (8)
434return (message.Body.ReturnValue != null && message.Body.Parts.Count == 0 && message.Body.ReturnValue.Type == typeof(Message)) || 435(message.Body.ReturnValue == null && message.Body.Parts.Count == 1 && message.Body.Parts[0].Type == typeof(Message)); 1293public object DeserializeReply(Message message, object[] parameters) 1298public void DeserializeRequest(Message message, object[] parameters) 1303public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 1305return result as Message; 1308public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 1310return parameters[0] as Message;
System\ServiceModel\Description\WebScriptClientGenerator.cs (5)
67public Message Get(Message message) 74Message responseMessage = Message.CreateMessage(MessageVersion.None, string.Empty); 81Message response = new WebScriptMetadataMessage(string.Empty, proxyContent);
System\ServiceModel\Description\WebScriptEnablingBehavior.cs (5)
324public override void AfterReceiveReply(ref Message reply, object correlationState) 385public void ProvideFault(Exception error, MessageVersion version, ref Message fault) 396fault = Message.CreateMessage(version, action, new JsonFaultBodyWriter(innerFault, this.includeExceptionDetailInFaults)); 404Message newMessage = Message.CreateMessage(version, fault.Headers.Action, new JsonFaultBodyWriter(innerFault, this.includeExceptionDetailInFaults));
System\ServiceModel\Dispatcher\CompositeClientFormatter.cs (2)
22public object DeserializeReply(Message message, object[] parameters) 27public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
System\ServiceModel\Dispatcher\CompositeDispatchFormatter.cs (2)
22public void DeserializeRequest(Message message, object[] parameters) 27public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result)
System\ServiceModel\Dispatcher\ContentTypeSettingClientMessageFormatter.cs (4)
39public object DeserializeReply(Message message, object[] parameters) 44public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 46Message message = this.innerFormatter.SerializeRequest(messageVersion, parameters); 54static void AddRequestContentTypeProperty(Message message, string contentType)
System\ServiceModel\Dispatcher\ContentTypeSettingDispatchMessageFormatter.cs (4)
31public void DeserializeRequest(Message message, object[] parameters) 36public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 38Message message = this.innerFormatter.SerializeReply(messageVersion, parameters, result); 46static void AddResponseContentTypeProperty(Message message, string contentType)
System\ServiceModel\Dispatcher\DataContractJsonSerializerOperationFormatter.cs (2)
111protected override void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest) 228protected override void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest)
System\ServiceModel\Dispatcher\DemultiplexingClientMessageFormatter.cs (2)
34public object DeserializeReply(Message message, object[] parameters) 61public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
System\ServiceModel\Dispatcher\DemultiplexingDispatchMessageFormatter.cs (3)
35public void DeserializeRequest(Message message, object[] parameters) 62public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 84internal static bool TryGetEncodingFormat(Message message, out WebContentFormat format)
System\ServiceModel\Dispatcher\FormatSelectingMessageInspector.cs (2)
63public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext) 95public void BeforeSendReply(ref Message reply, object correlationState)
System\ServiceModel\Dispatcher\HelpPage.cs (5)
49Message GetHelpPage() 64Message GetOperationHelpPage(string operation) 225return typeof(Message); 250return typeof(Message); 308else if (typeof(Message).IsAssignableFrom(type))
System\ServiceModel\Dispatcher\HttpStreamFormatter.cs (11)
38public object DeserializeReply(Message message, object[] parameters) 43public void DeserializeRequest(Message message, object[] parameters) 48public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 50Message message = CreateMessageFromStream(result); 58public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 60Message message = CreateMessageFromStream(parameters[0]); 68internal static bool IsEmptyMessage(Message message) 73Message CreateMessageFromStream(object data) 75Message result; 78result = Message.CreateMessage(MessageVersion.None, (string) null); 93Stream GetStreamFromMessage(Message message, bool isRequest)
System\ServiceModel\Dispatcher\HttpUnhandledOperationInvoker.cs (4)
37Message message = inputs[0] as Message; 55Message redirectResult = WebOperationContext.Current.CreateStreamResponse(s => HelpHtmlBuilder.CreateTransferRedirectPage(to.AbsoluteUri, newLocation.AbsoluteUri).Save(s, SaveOptions.OmitDuplicateNamespaces), Atom10Constants.HtmlMediaType); 75Message result = null;
System\ServiceModel\Dispatcher\JavascriptCallbackMessageInspector.cs (3)
32public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext) 44public void BeforeSendReply(ref Message reply, object correlationState) 77Message nullJsonMessage = WebOperationContext.Current.CreateJsonResponse<object>(null);
System\ServiceModel\Dispatcher\MultiplexingDispatchMessageFormatter.cs (3)
47public void DeserializeRequest(Message message, object[] parameters) 52public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 108Message message = this.formatters[format].SerializeReply(messageVersion, parameters, result);
System\ServiceModel\Dispatcher\SingleBodyParameterDataContractMessageFormatter.cs (3)
89protected override object ReadObject(Message message) 99protected override void AttachMessageProperties(Message message, bool isRequest) 163protected override void ValidateMessageFormatProperty(Message message)
System\ServiceModel\Dispatcher\SingleBodyParameterMessageFormatter.cs (21)
81public object DeserializeReply(Message message, object[] parameters) 90public void DeserializeRequest(Message message, object[] parameters) 100public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 106Message message = Message.CreateMessage(messageVersion, (string)null, CreateBodyWriter(result)); 115public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 121Message message = Message.CreateMessage(messageVersion, (string)null, CreateBodyWriter(parameters[0])); 162internal static void SuppressReplyEntityBody(Message message) 187internal static void SuppressRequestEntityBody(Message message) 212protected virtual void AttachMessageProperties(Message message, bool isRequest) 220protected virtual void ValidateMessageFormatProperty(Message message) 286protected virtual object ReadObject(Message message) 318public object DeserializeReply(Message message, object[] parameters) 323public void DeserializeRequest(Message message, object[] parameters) 327public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 329Message reply = Message.CreateMessage(messageVersion, (string)null); 338public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 340Message request = Message.CreateMessage(messageVersion, (string)null);
System\ServiceModel\Dispatcher\UriTemplateClientFormatter.cs (3)
50public object DeserializeReply(Message message, object[] parameters) 55public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) 79Message m = inner.SerializeRequest(messageVersion, innerParameters);
System\ServiceModel\Dispatcher\UriTemplateDispatchFormatter.cs (2)
48public void DeserializeRequest(Message message, object[] parameters) 111public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result)
System\ServiceModel\Dispatcher\WebErrorHandler.cs (4)
39public void ProvideFault(Exception error, MessageVersion version, ref Message fault) 132Message CreateHtmlResponse(Exception error) 149Message response = new HttpStreamMessage(bodyWriter); 161static HttpResponseMessageProperty GetResponseProperty(WebOperationContext currentContext, Message response)
System\ServiceModel\Dispatcher\WebFaultClientMessageInspector.cs (2)
21public virtual void AfterReceiveReply(ref Message reply, object correlationState) 33public object BeforeSendRequest(ref Message request, IClientChannel channel)
System\ServiceModel\Dispatcher\WebHttpDispatchOperationSelector.cs (6)
151public string SelectOperation(ref Message message) 177protected virtual string SelectOperation(ref Message message, out bool uriMatched) 292bool CanUriMatch(UriTemplateTable methodSpecificTable, Uri to, HttpRequestMessageProperty prop, Message message, out string operationName) 307void AddUriTemplateMatch(UriTemplateMatch match, HttpRequestMessageProperty requestProp, Message message) 313bool ShouldRedirectToUriWithSlashAtTheEnd(UriTemplateTable methodSpecificTable, Message message, Uri to) 358static string GetAuthority(Message message)
System\ServiceModel\Dispatcher\WebScriptMetadataFormatter.cs (3)
11public void DeserializeRequest(Message message, object[] parameters) 16public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) 18return result as Message;
System\ServiceModel\Web\WebOperationContext.cs (40)
93public Message CreateJsonResponse<T>(T instance) 100public Message CreateJsonResponse<T>(T instance, DataContractJsonSerializer serializer) 106Message message = Message.CreateMessage(MessageVersion.None, (string)null, instance, serializer); 112public Message CreateXmlResponse<T>(T instance) 118public Message CreateXmlResponse<T>(T instance, System.Runtime.Serialization.XmlObjectSerializer serializer) 124Message message = Message.CreateMessage(MessageVersion.None, (string)null, instance, serializer); 130public Message CreateXmlResponse<T>(T instance, XmlSerializer serializer) 136Message message = Message.CreateMessage(MessageVersion.None, (string)null, new XmlSerializerBodyWriter(instance, serializer)); 143public Message CreateXmlResponse(XDocument document) 149Message message; 152message = Message.CreateMessage(MessageVersion.None, (string)null); 156message = Message.CreateMessage(MessageVersion.None, (string)null, document.CreateReader()); 164public Message CreateXmlResponse(XElement element) 170Message message = Message.CreateMessage(MessageVersion.None, (string)null, element.CreateReader()); 176public Message CreateAtom10Response(SyndicationItem item) 182Message message = Message.CreateMessage(MessageVersion.None, (string)null, item.GetAtom10Formatter()); 188public Message CreateAtom10Response(SyndicationFeed feed) 194Message message = Message.CreateMessage(MessageVersion.None, (string)null, feed.GetAtom10Formatter()); 200public Message CreateAtom10Response(ServiceDocument document) 206Message message = Message.CreateMessage(MessageVersion.None, (string)null, document.GetFormatter()); 212public Message CreateTextResponse(string text) 217public Message CreateTextResponse(string text, string contentType) 222public Message CreateTextResponse(string text, string contentType, Encoding encoding) 237Message message = new HttpStreamMessage(StreamBodyWriter.CreateStreamBodyWriter((stream) => 253public Message CreateTextResponse(Action<TextWriter> textWriter, string contentType) 263public Message CreateTextResponse(Action<TextWriter> textWriter, string contentType, Encoding encoding) 278Message message = new HttpStreamMessage(StreamBodyWriter.CreateStreamBodyWriter((stream) => 290public Message CreateStreamResponse(Stream stream, string contentType) 300Message message = ByteStreamMessage.CreateMessage(stream); 307public Message CreateStreamResponse(StreamBodyWriter bodyWriter, string contentType) 317Message message = new HttpStreamMessage(bodyWriter); 323public Message CreateStreamResponse(Action<Stream> streamWriter, string contentType) 333Message message = new HttpStreamMessage(StreamBodyWriter.CreateStreamBodyWriter(streamWriter));
System.WorkflowServices (11)
System\ServiceModel\Dispatcher\DurableErrorHandler.cs (2)
36public void ProvideFault(Exception error, MessageVersion version, ref Message fault) 56fault = Message.CreateMessage(version, messageFault, action);
System\ServiceModel\Dispatcher\DurableInstanceContextProvider.cs (3)
47public virtual InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel) 83public virtual void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel) 196protected virtual Guid GetInstanceIdFromMessage(Message message)
System\ServiceModel\Dispatcher\DurableInstanceProvider.cs (1)
22public object GetInstance(InstanceContext instanceContext, Message message)
System\ServiceModel\Dispatcher\DurableMessageDispatchInspector.cs (2)
28public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext) 52public void BeforeSendReply(ref Message reply, object correlationState)
System\ServiceModel\Dispatcher\WorkflowInstanceContextProvider.cs (2)
50public override InstanceContext GetExistingInstanceContext(Message message, IContextChannel channel) 81public override void InitializeInstanceContext(InstanceContext instanceContext, Message message, IContextChannel channel)
System\Workflow\Activities\Design\ServiceOperationDetailViewControl.cs (1)
844type.Equals(typeof(System.ServiceModel.Channels.Message)) ||