2 instantiations of MsmqReceiveHelper
System.ServiceModel (2)
System\ServiceModel\Channels\MsmqInputChannelBase.cs (1)
23this.receiver = new MsmqReceiveHelper(listener.ReceiveParameters, listener.Uri, messagePool, this, listener);
System\ServiceModel\Channels\MsmqInputSessionChannelListener.cs (1)
20this.receiver = new MsmqReceiveHelper(
30 references to MsmqReceiveHelper
System.ServiceModel (30)
System\ServiceModel\Channels\Msmq.cs (2)
65internal static IPoisonHandlingStrategy CreatePoisonHandler(MsmqReceiveHelper receiver) 87internal static MsmqQueue CreateMsmqQueue(MsmqReceiveHelper receiver)
System\ServiceModel\Channels\Msmq3PoisonHandler.cs (3)
14MsmqReceiveHelper receiver; 18internal Msmq3PoisonHandler(MsmqReceiveHelper receiver) 62MsmqReceiveHelper.TryAbortTransactionCurrent();
System\ServiceModel\Channels\Msmq4PoisonHandler.cs (6)
20MsmqReceiveHelper receiver; 32public Msmq4PoisonHandler(MsmqReceiveHelper receiver) 156MsmqReceiveHelper.MoveReceivedMessage(this.lockQueueForReceive, this.retryQueueForMove, messageProperty.LookupId); 199MsmqReceiveHelper.MoveReceivedMessage(this.mainQueue, this.retryQueueForMove, messageProperty.LookupId); 228MsmqReceiveHelper.TryAbortTransactionCurrent(); 241MsmqReceiveHelper.MoveReceivedMessage(disposeFromQueue, this.poisonQueue, messageProperty.LookupId);
System\ServiceModel\Channels\Msmq4SubqueuePoisonHandler.cs (3)
11MsmqReceiveHelper receiver; 13public Msmq4SubqueuePoisonHandler(MsmqReceiveHelper receiver) 47MsmqReceiveHelper.TryAbortTransactionCurrent();
System\ServiceModel\Channels\MsmqDecodeHelper.cs (3)
61internal static Message DecodeTransportDatagram(MsmqInputChannelListener listener, MsmqReceiveHelper receiver, MsmqInputMessage msmqMessage, MsmqMessageProperty messageProperty) 183MsmqReceiveHelper receiver = listener.MsmqReceiveHelper; 356internal static Message DecodeIntegrationDatagram(MsmqIntegrationChannelListener listener, MsmqReceiveHelper receiver, MsmqIntegrationInputMessage msmqMessage, MsmqMessageProperty messageProperty)
System\ServiceModel\Channels\MsmqDiagnostics.cs (3)
48public static ServiceModelActivity StartListenAtActivity(MsmqReceiveHelper receiver) 63public static Activity BoundOpenOperation(MsmqReceiveHelper receiver) 76public static Activity BoundReceiveOperation(MsmqReceiveHelper receiver)
System\ServiceModel\Channels\MsmqInputChannelBase.cs (2)
14MsmqReceiveHelper receiver; 37protected MsmqReceiveHelper MsmqReceiveHelper
System\ServiceModel\Channels\MsmqInputSessionChannelListener.cs (2)
13MsmqReceiveHelper receiver; 34internal MsmqReceiveHelper MsmqReceiveHelper
System\ServiceModel\Channels\MsmqNonTransactedPoisonHandler.cs (2)
8MsmqReceiveHelper receiver; 10internal MsmqNonTransactedPoisonHandler(MsmqReceiveHelper receiver)
System\ServiceModel\Channels\MsmqReceiveHelper.cs (4)
325MsmqReceiveHelper receiver; 333internal TryTransactedReceiveAsyncResult(MsmqReceiveHelper receiver, MsmqInputMessage msmqMessage, 384MsmqReceiveHelper receiver; 389internal TryNonTransactedReceiveAsyncResult(MsmqReceiveHelper receiver, MsmqInputMessage msmqMessage, TimeSpan timeout, AsyncCallback callback, object state)