54 references to MsmqTransactionMode
System.ServiceModel (54)
System\ServiceModel\Channels\Msmq4PoisonHandler.cs (1)
314
this.retryQueueForPeek.TryMoveMessage(this.retryQueueMessage.LookupId.Value, this.mainQueueForMove,
MsmqTransactionMode
.Single);
System\ServiceModel\Channels\MsmqDefaultLockingQueue.cs (2)
34
public override ReceiveResult TryReceive(NativeMsmqMessage message, TimeSpan timeout,
MsmqTransactionMode
transactionMode)
234
MsmqTransactionMode
.CurrentOrThrow, UnsafeNativeMethods.MQ_LOOKUP_RECEIVE_CURRENT);
System\ServiceModel\Channels\MsmqInputChannelBase.cs (4)
163
this.ReceiveParameters.ExactlyOnce ?
MsmqTransactionMode
.CurrentOrNone :
MsmqTransactionMode
.None,
212
this.ReceiveParameters.ExactlyOnce ?
MsmqTransactionMode
.CurrentOrNone :
MsmqTransactionMode
.None,
System\ServiceModel\Channels\MsmqInputSessionChannelListener.cs (2)
86
bool retval = this.receiver.TryReceive(msmqMessage, timeout,
MsmqTransactionMode
.CurrentOrThrow, out property);
140
MsmqTransactionMode
.CurrentOrThrow,
System\ServiceModel\Channels\MsmqOutputChannel.cs (3)
14
MsmqTransactionMode
transactionMode;
105
this.transactionMode =
MsmqTransactionMode
.CurrentOrSingle;
109
this.transactionMode =
MsmqTransactionMode
.None;
System\ServiceModel\Channels\MsmqOutputSessionChannel.cs (1)
106
this.msmqQueue.Send(msmqMessage,
MsmqTransactionMode
.CurrentOrSingle);
System\ServiceModel\Channels\MsmqQueue.cs (26)
334
int TryMoveMessageDtcTransacted(long lookupId, MsmqQueueHandle sourceQueueHandle, MsmqQueueHandle destinationQueueHandle,
MsmqTransactionMode
transactionMode)
356
public MoveReceiveResult TryMoveMessage(long lookupId, MsmqQueue destinationQueue,
MsmqTransactionMode
transactionMode)
398
public virtual ReceiveResult TryReceive(NativeMsmqMessage message, TimeSpan timeout,
MsmqTransactionMode
transactionMode)
403
ReceiveResult TryReceiveInternal(NativeMsmqMessage message, TimeSpan timeout,
MsmqTransactionMode
transactionMode, int action)
442
public MoveReceiveResult TryReceiveByLookupId(long lookupId, NativeMsmqMessage message,
MsmqTransactionMode
transactionMode)
447
public MoveReceiveResult TryReceiveByLookupId(long lookupId, NativeMsmqMessage message,
MsmqTransactionMode
transactionMode, int action)
493
protected unsafe int ReceiveByLookupIdCoreDtcTransacted(MsmqQueueHandle handle, long lookupId, NativeMsmqMessage message,
MsmqTransactionMode
transactionMode, int action)
524
unsafe int ReceiveByLookupIdCore(MsmqQueueHandle handle, long lookupId, NativeMsmqMessage message,
MsmqTransactionMode
transactionMode, int action)
545
unsafe int ReceiveCoreDtcTransacted(MsmqQueueHandle handle, NativeMsmqMessage message, TimeSpan timeout,
MsmqTransactionMode
transactionMode, int action)
578
unsafe int ReceiveCore(MsmqQueueHandle handle, NativeMsmqMessage message, TimeSpan timeout,
MsmqTransactionMode
transactionMode, int action)
600
protected IDtcTransaction GetNativeTransaction(
MsmqTransactionMode
transactionMode)
607
if (transactionMode ==
MsmqTransactionMode
.CurrentOrThrow)
616
return TryReceiveInternal(message, timeout,
MsmqTransactionMode
.None,
620
bool RequiresDtcTransaction(
MsmqTransactionMode
transactionMode)
624
case
MsmqTransactionMode
.None:
625
case
MsmqTransactionMode
.Single:
627
case
MsmqTransactionMode
.CurrentOrSingle:
628
case
MsmqTransactionMode
.CurrentOrNone:
629
case
MsmqTransactionMode
.CurrentOrThrow:
636
int GetTransactionConstant(
MsmqTransactionMode
transactionMode)
640
case
MsmqTransactionMode
.CurrentOrNone:
641
case
MsmqTransactionMode
.None:
643
case
MsmqTransactionMode
.Single:
644
case
MsmqTransactionMode
.CurrentOrSingle:
651
int SendDtcTransacted(NativeMsmqMessage message,
MsmqTransactionMode
transactionMode)
683
public void Send(NativeMsmqMessage message,
MsmqTransactionMode
transactionMode)
System\ServiceModel\Channels\MsmqReceiveHelper.cs (6)
201
result = queue.TryReceiveByLookupId(messageProperty.LookupId, emptyMessage,
MsmqTransactionMode
.CurrentOrThrow);
232
result = queueFrom.TryMoveMessage(lookupId, queueTo,
MsmqTransactionMode
.Single);
264
internal bool TryReceive(MsmqInputMessage msmqMessage, TimeSpan timeout,
MsmqTransactionMode
transactionMode, out MsmqMessageProperty property)
289
internal IAsyncResult BeginTryReceive(MsmqInputMessage msmqMessage, TimeSpan timeout,
MsmqTransactionMode
transactionMode, AsyncCallback callback, object state)
330
MsmqTransactionMode
transactionMode;
334
TimeSpan timeout,
MsmqTransactionMode
transactionMode, AsyncCallback callback, object state)
System\ServiceModel\Channels\MsmqSubqueueLockingQueue.cs (6)
125
public override ReceiveResult TryReceive(NativeMsmqMessage message, TimeSpan timeout,
MsmqTransactionMode
transactionMode)
152
moveResult = this.TryMoveMessage(lookupId, this.lockQueueForMove,
MsmqTransactionMode
.None);
167
lookupIdReceiveResult = this.lockQueueForReceive.TryReceiveByLookupId(lookupId, message,
MsmqTransactionMode
.None, UnsafeNativeMethods.MQ_LOOKUP_PEEK_CURRENT);
195
receiveResult = this.lockQueueForReceive.TryReceiveByLookupId(lookupId, emptyMessage,
MsmqTransactionMode
.CurrentOrNone);
222
moveResult = this.lockQueueForReceive.TryMoveMessage(lookupId, this.mainQueueForMove,
MsmqTransactionMode
.None);
341
lockQueue.TryMoveMessage(message.lookupId.Value, this.mainQueueForMove,
MsmqTransactionMode
.None);
System\ServiceModel\MsmqIntegration\MsmqIntegrationOutputChannel.cs (3)
17
MsmqTransactionMode
transactionMode;
83
this.transactionMode =
MsmqTransactionMode
.CurrentOrSingle;
87
this.transactionMode =
MsmqTransactionMode
.None;