1 write to service
System.ServiceModel.Routing (1)
System\ServiceModel\Routing\ProcessMessagesAsyncResult.cs (1)
38this.service = service;
38 references to service
System.ServiceModel.Routing (38)
System\ServiceModel\Routing\ProcessMessagesAsyncResult.cs (38)
59messageRpc.RouteToEndpoints<TContract>(this.service.RoutingConfig); 60this.service.SessionMessages.Add(messageRpc); 62this.sessionMessageIndex = this.service.SessionMessages.Count - 1; 106this.service.ResetSession(); 116this.service.CreateNewTransactionIfNeeded(this.service.SessionMessages[0]); 154MessageRpc messageRpc = this.service.SessionMessages[this.sessionMessageIndex]; 170this.client = this.service.GetOrCreateClient<TContract>(endpointTrait, messageRpc.Impersonating); 192Transaction transaction = this.service.GetTransactionForSending(messageRpc); 284MessageRpc messageRpc = this.service.SessionMessages[this.sessionMessageIndex]; 288currentDest.TransmitSucceeded(this.service.GetTransactionForSending(messageRpc)); 308this.service.SessionMessages.RemoveAt(this.sessionMessageIndex); 312if (++this.sessionMessageIndex >= this.service.SessionMessages.Count) 323foreach (MessageRpc messageRpc in this.service.SessionMessages) 355else if (this.service.RetryTransaction != null || this.channelExtension.TransactedReceiveEnabled) 374if (this.service.RetryTransaction != null || this.channelExtension.TransactedReceiveEnabled) 405else if (this.service.RetryTransaction != null || this.channelExtension.TransactedReceiveEnabled) 432using (this.PrepareTransactionalCall(this.service.GetTransactionForSending(null))) 507MessageRpc messageRpc = this.service.SessionMessages[this.sessionMessageIndex]; 528SessionChannels sessionChannels = this.service.GetSessionChannels(messageRpc.Impersonating); 557else if (this.service.GetTransactionForSending(messageRpc) == null) 561this.service.SessionException = e; 597if (this.service.SessionMessages.Count == 0) 600Fx.Assert(!this.service.ChannelExtension.TransactedReceiveEnabled, "Should only happen for non-transactional cases"); 604foreach (MessageRpc messageRpc in this.service.SessionMessages) 629if (this.service.SessionException != null) 632this.Fault(this.service.SessionException); 637MessageRpc messageRpc = this.service.SessionMessages[this.sessionMessageIndex]; 646using (this.PrepareTransactionalCall(this.service.GetTransactionForSending(messageRpc))) 696MessageRpc messageRpc = this.service.SessionMessages[this.sessionMessageIndex]; 699if (++this.sessionMessageIndex >= this.service.SessionMessages.Count) 708if (this.service.RetryTransaction != null) 712TD.RoutingServiceCommittingTransaction(this.service.RetryTransaction.TransactionInformation.LocalIdentifier); 715IAsyncResult result = this.service.RetryTransaction.BeginCommit( 727Transaction transaction = this.service.GetTransactionForSending(null); 760this.service.RetryTransaction.EndCommit(result); 771exception = this.service.SessionException; 789this.service.ResetSession();