2 types derived from MsmqQueue
System.ServiceModel (2)
System\ServiceModel\Channels\MsmqDefaultLockingQueue.cs (1)
15class MsmqDefaultLockingQueue : MsmqQueue, ILockingQueue
System\ServiceModel\Channels\MsmqSubqueueLockingQueue.cs (1)
15class MsmqSubqueueLockingQueue : MsmqQueue, ILockingQueue
15 instantiations of MsmqQueue
System.ServiceModel (15)
System\ServiceModel\Channels\Msmq.cs (1)
102return new MsmqQueue(receiver.MsmqReceiveParameters.AddressTranslator.UriToFormatName(receiver.ListenUri), UnsafeNativeMethods.MQ_RECEIVE_ACCESS);
System\ServiceModel\Channels\Msmq4PoisonHandler.cs (4)
61this.mainQueueForMove = new MsmqQueue(this.mainQueueName, UnsafeNativeMethods.MQ_MOVE_ACCESS); 63this.poisonQueue = new MsmqQueue(this.poisonQueueName, UnsafeNativeMethods.MQ_MOVE_ACCESS); 64this.retryQueueForMove = new MsmqQueue(this.retryQueueName, UnsafeNativeMethods.MQ_MOVE_ACCESS); 65this.retryQueueForPeek = new MsmqQueue(this.retryQueueName, UnsafeNativeMethods.MQ_RECEIVE_ACCESS);
System\ServiceModel\Channels\MsmqOutputChannel.cs (1)
96this.msmqQueue = new MsmqQueue(this.factory.AddressTranslator.UriToFormatName(this.RemoteAddress.Uri),
System\ServiceModel\Channels\MsmqOutputSessionChannel.cs (1)
164this.msmqQueue = new MsmqQueue(this.Factory.AddressTranslator.UriToFormatName(this.RemoteAddress.Uri),
System\ServiceModel\Channels\MsmqQueue.cs (1)
231using (MsmqQueue msmqQueue = new MsmqQueue(formatName, accessType))
System\ServiceModel\Channels\MsmqSubqueueLockingQueue.cs (6)
47this.lockQueueForReceive = new MsmqQueue(this.lockQueueName, UnsafeNativeMethods.MQ_RECEIVE_ACCESS, UnsafeNativeMethods.MQ_DENY_RECEIVE_SHARE); 48this.lockQueueForMove = new MsmqQueue(this.lockQueueName, UnsafeNativeMethods.MQ_MOVE_ACCESS); 49this.mainQueueForMove = new MsmqQueue(this.formatName, UnsafeNativeMethods.MQ_MOVE_ACCESS); 118this.lockQueueForReceive = new MsmqQueue(this.lockQueueName, UnsafeNativeMethods.MQ_RECEIVE_ACCESS, UnsafeNativeMethods.MQ_DENY_RECEIVE_SHARE); 119this.lockQueueForMove = new MsmqQueue(this.lockQueueName, UnsafeNativeMethods.MQ_MOVE_ACCESS); 300lockQueue = new MsmqQueue(formatName, accessMode, shareMode);
System\ServiceModel\MsmqIntegration\MsmqIntegrationOutputChannel.cs (1)
75this.msmqQueue = new MsmqQueue(this.factory.AddressTranslator.UriToFormatName(this.RemoteAddress.Uri), UnsafeNativeMethods.MQ_SEND_ACCESS);
63 references to MsmqQueue
System.ServiceModel (63)
System\ServiceModel\Channels\Msmq.cs (2)
23MsmqQueue.GetMsmqInformation(ref version, ref activeDirectoryEnabled); 87internal static MsmqQueue CreateMsmqQueue(MsmqReceiveHelper receiver)
System\ServiceModel\Channels\Msmq4PoisonHandler.cs (10)
12MsmqQueue mainQueue; 13MsmqQueue mainQueueForMove; 14MsmqQueue retryQueueForPeek; 15MsmqQueue retryQueueForMove; 16MsmqQueue poisonQueue; 17MsmqQueue lockQueueForReceive; 219private void InternalFinalDisposition(MsmqQueue disposeFromQueue, MsmqMessageProperty messageProperty) 275MsmqQueue.ReceiveResult receiveResult = MsmqQueue.ReceiveResult.Unknown; 285if (MsmqQueue.ReceiveResult.MessageReceived == receiveResult)
System\ServiceModel\Channels\MsmqOutputChannel.cs (1)
13MsmqQueue msmqQueue;
System\ServiceModel\Channels\MsmqOutputSessionChannel.cs (1)
16MsmqQueue msmqQueue;
System\ServiceModel\Channels\MsmqQueue.cs (4)
231using (MsmqQueue msmqQueue = new MsmqQueue(formatName, accessType)) 356public MoveReceiveResult TryMoveMessage(long lookupId, MsmqQueue destinationQueue, MsmqTransactionMode transactionMode) 753MsmqQueue msmqQueue; 764public TryReceiveAsyncResult(MsmqQueue msmqQueue, NativeMsmqMessage message, TimeSpan timeout,
System\ServiceModel\Channels\MsmqReceiveContextLockManager.cs (3)
19MsmqQueue queue; 26public MsmqReceiveContextLockManager(MsmqReceiveContextSettings receiveContextSettings, MsmqQueue queue) 41public MsmqQueue Queue
System\ServiceModel\Channels\MsmqReceiveHelper.cs (25)
54MsmqQueue queue; 112internal MsmqQueue Queue 188internal void DropOrRejectReceivedMessage(MsmqQueue queue, MsmqMessageProperty messageProperty, bool reject) 194MsmqQueue.MoveReceiveResult result = MsmqQueue.MoveReceiveResult.Unknown; 202if (MsmqQueue.MoveReceiveResult.Succeeded == result && reject) 208if (result == MsmqQueue.MoveReceiveResult.Succeeded) 212if (result != MsmqQueue.MoveReceiveResult.MessageLockedUnderTransaction) 224internal static void MoveReceivedMessage(MsmqQueue queueFrom, MsmqQueue queueTo, long lookupId) 229MsmqQueue.MoveReceiveResult result = MsmqQueue.MoveReceiveResult.Unknown; 234if (result != MsmqQueue.MoveReceiveResult.MessageLockedUnderTransaction) 250return (MsmqQueue.ReceiveResult.Timeout != this.queue.TryPeek(message, timeout)); 268MsmqQueue.ReceiveResult receiveResult = this.Queue.TryReceive(msmqMessage, timeout, transactionMode); 269if (MsmqQueue.ReceiveResult.OperationCancelled == receiveResult) 271if (MsmqQueue.ReceiveResult.Timeout == receiveResult) 383MsmqQueue.ReceiveResult receiveResult; 423if (MsmqQueue.ReceiveResult.Timeout == asyncResult.receiveResult) 425else if (MsmqQueue.ReceiveResult.OperationCancelled == asyncResult.receiveResult) 438MsmqQueue msmqQueue; 443public WaitForMessageAsyncResult(MsmqQueue msmqQueue, TimeSpan timeout, AsyncCallback callback, object state) 459MsmqQueue.ReceiveResult receiveResult = MsmqQueue.ReceiveResult.Unknown; 472this.successResult = receiveResult != MsmqQueue.ReceiveResult.Timeout;
System\ServiceModel\Channels\MsmqSubqueueLockingQueue.cs (10)
19MsmqQueue mainQueueForMove; 20MsmqQueue lockQueueForMove; 21MsmqQueue lockQueueForReceive; 68public MsmqQueue LockQueueForReceive 198if (receiveResult != MsmqQueue.MoveReceiveResult.MessageLockedUnderTransaction) 223if (moveResult != MsmqQueue.MoveReceiveResult.MessageLockedUnderTransaction) 276MsmqQueue collectQueue; 288private bool TryOpenLockQueueForCollection(string subqueueName, out MsmqQueue lockQueue) 298if (MsmqQueue.IsQueueOpenable(formatName, accessMode, shareMode, out error)) 328private void CollectLocks(MsmqQueue lockQueue)
System\ServiceModel\Channels\MsmqVerifier.cs (6)
47if (!MsmqQueue.IsWriteable(dlqFormatName)) 51if (!MsmqQueue.TryGetIsTransactional(dlqFormatName, out isQueueTx) || !isQueueTx) 87if (!MsmqQueue.IsReadable(formatName, out msmqException)) 95knownTxStatus = MsmqQueue.TryGetIsTransactional(formatName, out isQueueTx); 99knownTxStatus = MsmqQueue.TryGetIsTransactional(MsmqUri.ActiveDirectoryAddressTranslator.UriToFormatName(listenUri), out isQueueTx); 127if (!MsmqQueue.IsMoveable(formatName + ";retry"))
System\ServiceModel\MsmqIntegration\MsmqIntegrationOutputChannel.cs (1)
16MsmqQueue msmqQueue;