78 references to MessageQueueTransactionType
System.Messaging (78)
System\Messaging\MessageEnumerator.cs (10)
53
MessageQueueTransactionType
.None);
197
return RemoveCurrent(TimeSpan.Zero, null,
MessageQueueTransactionType
.None);
210
return RemoveCurrent(TimeSpan.Zero, transaction,
MessageQueueTransactionType
.None);
218
public Message RemoveCurrent(
MessageQueueTransactionType
transactionType)
221
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
233
return RemoveCurrent(timeout, null,
MessageQueueTransactionType
.None);
246
return RemoveCurrent(timeout, transaction,
MessageQueueTransactionType
.None);
254
public Message RemoveCurrent(TimeSpan timeout,
MessageQueueTransactionType
transactionType)
257
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
262
private Message RemoveCurrent(TimeSpan timeout, MessageQueueTransaction transaction,
MessageQueueTransactionType
transactionType)
System\Messaging\MessageQueue.cs (64)
2275
return ReceiveCurrent(InfiniteTimeout, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, CursorHandle.NullHandle, MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2290
return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, CursorHandle.NullHandle, MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2302
return ReceiveCurrent(timeout, (int)action, cursor.Handle, MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2316
return ReceiveBy(id, TimeSpan.Zero, false, true, false, null,
MessageQueueTransactionType
.None);
2332
return ReceiveBy(id, timeout, false, true, true, null,
MessageQueueTransactionType
.None);
2347
return ReceiveBy(correlationId, TimeSpan.Zero, false, false, false, null,
MessageQueueTransactionType
.None);
2363
return ReceiveBy(correlationId, timeout, false, false, true, null,
MessageQueueTransactionType
.None);
2398
return ReceiveCurrent(InfiniteTimeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2414
return ReceiveCurrent(InfiniteTimeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, transaction,
MessageQueueTransactionType
.None);
2421
public Message Receive(
MessageQueueTransactionType
transactionType)
2424
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
2440
return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2449
return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, cursor.Handle, MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2466
return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, transaction,
MessageQueueTransactionType
.None);
2474
public Message Receive(TimeSpan timeout,
MessageQueueTransactionType
transactionType)
2477
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
2491
return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, cursor.Handle, MessageReadPropertyFilter, transaction,
MessageQueueTransactionType
.None);
2496
public Message Receive(TimeSpan timeout, Cursor cursor,
MessageQueueTransactionType
transactionType)
2499
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
2594
private Message ReceiveBy(string id, TimeSpan timeout, bool remove, bool compareId, bool throwTimeout, MessageQueueTransaction transaction,
MessageQueueTransactionType
transactionType)
2632
MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2651
this.MessageReadPropertyFilter, transaction,
MessageQueueTransactionType
.None);
2655
this.MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2662
MessageReadPropertyFilter, null,
MessageQueueTransactionType
.None);
2698
return ReceiveBy(id, TimeSpan.Zero, true, true, false, null,
MessageQueueTransactionType
.None);
2714
return ReceiveBy(id, TimeSpan.Zero, true, true, false, transaction,
MessageQueueTransactionType
.None);
2725
public Message ReceiveById(string id,
MessageQueueTransactionType
transactionType)
2728
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
2745
return ReceiveBy(id, timeout, true, true, true, null,
MessageQueueTransactionType
.None);
2763
return ReceiveBy(id, timeout, true, true, true, transaction,
MessageQueueTransactionType
.None);
2776
public Message ReceiveById(string id, TimeSpan timeout,
MessageQueueTransactionType
transactionType)
2779
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
2795
return ReceiveBy(correlationId, TimeSpan.Zero, true, false, false, null,
MessageQueueTransactionType
.None);
2812
return ReceiveBy(correlationId, TimeSpan.Zero, true, false, false, transaction,
MessageQueueTransactionType
.None);
2824
public Message ReceiveByCorrelationId(string correlationId,
MessageQueueTransactionType
transactionType)
2827
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
2844
return ReceiveBy(correlationId, timeout, true, false, true, null,
MessageQueueTransactionType
.None);
2862
return ReceiveBy(correlationId, timeout, true, false, true, transaction,
MessageQueueTransactionType
.None);
2875
public Message ReceiveByCorrelationId(string correlationId, TimeSpan timeout,
MessageQueueTransactionType
transactionType)
2878
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
2886
return InternalReceiveByLookupId(true, MessageLookupAction.Current, lookupId, null,
MessageQueueTransactionType
.None);
2889
public Message ReceiveByLookupId(MessageLookupAction action, long lookupId,
MessageQueueTransactionType
transactionType)
2897
return InternalReceiveByLookupId(true, action, lookupId, transaction,
MessageQueueTransactionType
.None);
2902
return InternalReceiveByLookupId(false, MessageLookupAction.Current, lookupId, null,
MessageQueueTransactionType
.None);
2907
return InternalReceiveByLookupId(false, action, lookupId, null,
MessageQueueTransactionType
.None);
2914
MessageQueueTransaction internalTransaction,
MessageQueueTransactionType
transactionType)
2918
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
3016
internal unsafe Message ReceiveCurrent(TimeSpan timeout, int action, CursorHandle cursor, MessagePropertyFilter filter, MessageQueueTransaction internalTransaction,
MessageQueueTransactionType
transactionType)
3141
SendInternal(obj, null,
MessageQueueTransactionType
.None);
3157
SendInternal(obj, transaction,
MessageQueueTransactionType
.None);
3168
public void Send(object obj,
MessageQueueTransactionType
transactionType)
3171
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
3186
Send(obj, label, null,
MessageQueueTransactionType
.None);
3202
Send(obj, label, transaction,
MessageQueueTransactionType
.None);
3213
public void Send(object obj, string label,
MessageQueueTransactionType
transactionType)
3216
throw new InvalidEnumArgumentException("transactionType", (int)transactionType, typeof(
MessageQueueTransactionType
));
3221
private void Send(object obj, string label, MessageQueueTransaction transaction,
MessageQueueTransactionType
transactionType)
3248
private void SendInternal(object obj, MessageQueueTransaction internalTransaction,
MessageQueueTransactionType
transactionType)
4010
if ((
MessageQueueTransactionType
)transaction ==
MessageQueueTransactionType
.Automatic)
4052
if ((
MessageQueueTransactionType
)transaction ==
MessageQueueTransactionType
.Automatic)
4091
if ((
MessageQueueTransactionType
)transaction ==
MessageQueueTransactionType
.Automatic)
System\Messaging\ValidationUtility.cs (4)
77
public static bool ValidateMessageQueueTransactionType(
MessageQueueTransactionType
value)
82
return (value ==
MessageQueueTransactionType
.None) ||
83
(value ==
MessageQueueTransactionType
.Automatic) ||
84
(value ==
MessageQueueTransactionType
.Single);