1 write to messageRpc
System.ServiceModel.Routing (1)
System\ServiceModel\Routing\ProcessRequestAsyncResult.cs (1)
32this.messageRpc = new MessageRpc(message, OperationContext.Current, service.ChannelExtension.ImpersonationRequired);
30 references to messageRpc
System.ServiceModel.Routing (30)
System\ServiceModel\Routing\ProcessRequestAsyncResult.cs (30)
35TD.RoutingServiceProcessingMessage(this.messageRpc.EventTraceActivity, this.messageRpc.UniqueID, 36message.Headers.Action, this.messageRpc.OperationContext.EndpointDispatcher.EndpointAddress.Uri.ToString(), messageRpc.Transaction != null ? "True" : "False"); 41EndpointNameMessageFilter.Set(this.messageRpc.Message.Properties, service.ChannelExtension.EndpointName); 42this.messageRpc.RouteToSingleEndpoint<TContract>(this.service.RoutingConfig); 47throw FxTrace.Exception.AsError(new ConfigurationErrorsException(SR.ReqReplyMulticastNotSupported(this.messageRpc.OperationContext.Channel.LocalAddress), matchesException)); 58SendOperation sendOperation = this.messageRpc.Operations[0]; 59this.currentClient = this.service.GetOrCreateClient<TContract>(sendOperation.CurrentEndpoint, this.messageRpc.Impersonating); 63TD.RoutingServiceTransmittingMessage(this.messageRpc.EventTraceActivity, this.messageRpc.UniqueID, "0", this.currentClient.Key.ToString()); 68if (messageRpc.Transaction != null && sendOperation.HasAlternate) 70throw FxTrace.Exception.AsError(new ConfigurationErrorsException(SR.ErrorHandlingNotSupportedReqReplyTxn(this.messageRpc.OperationContext.Channel.LocalAddress))); 77message = messageRpc.CreateBuffer().CreateMessage(); 81message = messageRpc.Message; 87using (this.PrepareTransactionalCall(messageRpc.Transaction)) 96impersonationContext = messageRpc.PrepareCall(); 98result = this.currentClient.BeginOperation(message, messageRpc.Transaction, this.PrepareAsyncCompletion(operationCallback), this); 178TD.RoutingServiceTransmitSucceeded(this.messageRpc.EventTraceActivity, this.messageRpc.UniqueID, "0", this.currentClient.Key.ToString()); 186TD.RoutingServiceSendingResponse(this.messageRpc.EventTraceActivity, action); 191if (TD.RoutingServiceSendingFaultResponseIsEnabled()) { TD.RoutingServiceSendingFaultResponse(this.messageRpc.EventTraceActivity, responseMsg.Headers.Action); } 196if (TD.RoutingServiceCompletingTwoWayIsEnabled()) { TD.RoutingServiceCompletingTwoWay(this.messageRpc.EventTraceActivity); } 208SendOperation sendOperation = this.messageRpc.Operations[0]; 209if (TD.RoutingServiceTransmitFailedIsEnabled()) { TD.RoutingServiceTransmitFailed(this.messageRpc.EventTraceActivity, sendOperation.CurrentEndpoint.ToString(), exception); } 222if (messageRpc.Transaction == null && !this.abortedRetry) 233SessionChannels sessionChannels = this.service.GetSessionChannels(this.messageRpc.Impersonating); 258SessionChannels sessionChannels = this.service.GetSessionChannels(this.messageRpc.Impersonating); 272TD.RoutingServiceMovedToBackup(this.messageRpc.EventTraceActivity, messageRpc.UniqueID, "0", sendOperation.CurrentEndpoint.ToString());