21 instantiations of MessageQueue
SMSvcHost (1)
System\ServiceModel\Activation\MsmqActivation.cs (1)
590this.queue = new MQMessageQueue(this.queueName);
System.Messaging (20)
System\Messaging\Design\MessageQueueConverter.cs (1)
66newQueue = new MessageQueue(text);
System\Messaging\Design\QueuePathDialog.cs (4)
150MessageQueue queue = new MessageQueue(this.path); 156MessageQueue queue = new MessageQueue(this.path); 160MessageQueue validate = new MessageQueue(tempPath); 185OnSelectQueue(new MessageQueue(this.queuePath), this.lastPathType);
System\Messaging\Design\QueuePathEditor.cs (2)
47queue = new MessageQueue((string)value); 72value = new MessageQueue(dialog.Path);
System\Messaging\Message.cs (4)
346this.cachedAdminQueue = new MessageQueue("FORMATNAME:" + queueFormatName); 878this.cachedDestinationQueue = new MessageQueue("FORMATNAME:" + queueFormatName); 1444this.cachedResponseQueue = new MessageQueue("FORMATNAME:" + queueFormatName); 1824this.cachedTransactionStatusQueue = new MessageQueue("FORMATNAME:" + queueFormatName);
System\Messaging\MessageQueue.cs (4)
1685return new MessageQueue(path); 1737MessageQueue queue = new MessageQueue(path); 2049queues[index] = new MessageQueue("FormatName:DIRECT=OS:" + path); 2170queues[index] = new MessageQueue(String.Format(CultureInfo.InvariantCulture, "{0}\\{1}", machineName, queueName));
System\Messaging\MessageQueueEnumerator.cs (1)
216this.currentMessageQueue = new MessageQueue(currentItem, new Guid(currentGuid));
System\Messaging\MessageQueueInstaller.cs (3)
354MessageQueue queue = new MessageQueue(path); 405queue = new MessageQueue(Path); 490queue = new MessageQueue(Path);
System\Messaging\MessageQueuePermission.cs (1)
348MessageQueue queue = new MessageQueue(entry.Path);
208 references to MessageQueue
SMSvcHost (2)
System\ServiceModel\Activation\MsmqActivation.cs (2)
20using MQMessageQueue = System.Messaging.MessageQueue; 570MQMessageQueue queue;
System.Messaging (200)
System\Messaging\ActiveXMessageFormatter.cs (1)
24/// primitives, classes, enumeration, and other objects into and from <see cref='System.Messaging.MessageQueue'/>
System\Messaging\Cursor.cs (2)
19internal Cursor(MessageQueue queue) 23if (MessageQueue.IsFatalError(status))
System\Messaging\DefaultPropertiesToSend.cs (6)
26private MessageQueue cachedAdminQueue; 27private MessageQueue cachedResponseQueue; 28private MessageQueue cachedTransactionStatusQueue; 81public MessageQueue AdministrationQueue 302public MessageQueue ResponseQueue 377public MessageQueue TransactionStatusQueue
System\Messaging\Design\MessageQueueConverter.cs (6)
43internal static void AddToCache(MessageQueue queue) 61MessageQueue newQueue = GetFromCache(text); 87return ((MessageQueue)value).Path; 95internal static MessageQueue GetFromCache(string path) 99MessageQueue existingComponent = (MessageQueue)componentsCreated[path];
System\Messaging\Design\QueuePathDialog.cs (15)
52private MessageQueue selectedQueue; 53private delegate void FinishPopulateDelegate(MessageQueue[] queues); 54private delegate void SelectQueueDelegate(MessageQueue queue, int pathTypeIndex); 150MessageQueue queue = new MessageQueue(this.path); 156MessageQueue queue = new MessageQueue(this.path); 160MessageQueue validate = new MessageQueue(tempPath); 255this.icons.Images.Add(new Bitmap(typeof(MessageQueue), "Machine.bmp")); 256this.icons.Images.Add(new Bitmap(typeof(MessageQueue), "PublicQueue.bmp")); 302IEnumerator messageQueues = MessageQueue.GetMessageQueueEnumerator(); 306MessageQueue[] queues = new MessageQueue[100]; 310queues[index] = (MessageQueue)messageQueues.Current; 335public void SelectQueue(MessageQueue queue) 388private void OnPopulateTreeview(MessageQueue[] queues) 430private void OnSelectQueue(MessageQueue queue, int pathTypeIndex)
System\Messaging\Design\QueuePathEditor.cs (5)
43MessageQueue queue = null; 44if (value is MessageQueue) 45queue = (MessageQueue)value; 65if (context.Instance is MessageQueue || context.Instance is MessageQueueInstaller) 73MessageQueueConverter.AddToCache((MessageQueue)value);
System\Messaging\Message.cs (10)
56private MessageQueue cachedResponseQueue; 57private MessageQueue cachedTransactionStatusQueue; 58private MessageQueue cachedAdminQueue; 59private MessageQueue cachedDestinationQueue; 326public MessageQueue AdministrationQueue 860public MessageQueue DestinationQueue 1277if (!MessageQueue.Msmq3OrNewer) 1424public MessageQueue ResponseQueue 1663if (MessageQueue.IsFatalError(status)) 1804public MessageQueue TransactionStatusQueue
System\Messaging\MessageEnumerator.cs (4)
27private MessageQueue owner; 33internal MessageEnumerator(MessageQueue owner, bool useCorrectRemoveCurrent) 91if (MessageQueue.IsFatalError(status)) 183if (MessageQueue.IsFatalError(status))
System\Messaging\MessagePropertyFilter.cs (2)
652if (!MessageQueue.Msmq3OrNewer) 660if (!MessageQueue.Msmq3OrNewer)
System\Messaging\MessageQueue.cs (96)
160/// Initializes a new instance of the <see cref='System.Messaging.MessageQueue'/> class. To use the object instantiated by the default 161/// constructor, the <see cref='System.Messaging.MessageQueue.Path'/> 175/// Initializes a new instance of the <see cref='System.Messaging.MessageQueue'/> 189/// Initializes a new instance of the <see cref='System.Messaging.MessageQueue'/> 204/// Initializes a new instance of the <see cref='System.Messaging.MessageQueue'/> class that references the 217/// Initializes a new instance of the <see cref='System.Messaging.MessageQueue'/> class that references the 236/// Initializes a new instance of the <see cref='System.Messaging.MessageQueue'/> class that references the 359/// Gets a value indicating whether the <see cref='System.Messaging.MessageQueue'/> 383/// Gets a value indicating whether the <see cref='System.Messaging.MessageQueue'/> 451lock (MessageQueue.staticSyncRoot) 495/// default when sending messages to the queue referenced by this <see cref='System.Messaging.MessageQueue'/> 627this.formatName = MessageQueue.formatNameCache.Get(pathUpper); 655MessageQueue labeledQueue = ResolveQueueFromLabel(this.path, true); 665MessageQueue.formatNameCache.Put(pathUpper, formatName); 808/// the queue referenced by this <see cref='System.Messaging.MessageQueue'/> 1058/// Gets or sets the queue's path. When setting the <see cref='System.Messaging.MessageQueue.Path'/>, this points the <see cref='System.Messaging.MessageQueue'/> 1175MessageQueue labeledQueue = ResolveQueueFromLabel(this.path, true); 1348/// from the queue. This is a result of the asynchronous operation, <see cref='System.Messaging.MessageQueue.BeginPeek'/> 1376/// This is a result of the asynchronous operation <see cref='System.Messaging.MessageQueue.BeginReceive'/> 1518/// referenced by the <see cref='System.Messaging.MessageQueue'/> 1531/// referenced by the <see cref='System.Messaging.MessageQueue'/> . Waits the specified interval for 1545/// referenced by the <see cref='System.Messaging.MessageQueue'/> . Waits the specified interval 1558/// referenced by the <see cref='System.Messaging.MessageQueue'/> . Waits 1590/// Frees all resources allocated by the <see cref='System.Messaging.MessageQueue'/> 1640public static MessageQueue Create(string path) 1642return MessageQueue.Create(path, false); 1653public static MessageQueue Create(string path, bool transactional) 1682if (MessageQueue.IsFatalError(status)) 1696private static MessageQueue[] CreateMessageQueuesSnapshot(MessageQueueCriteria criteria) 1703private static MessageQueue[] CreateMessageQueuesSnapshot(MessageQueueCriteria criteria, bool checkSecurity) 1709MessageQueue messageQueue = (MessageQueue)messageQueues.Current; 1713MessageQueue[] queues = new MessageQueue[messageQueuesList.Count]; 1737MessageQueue queue = new MessageQueue(path); 1742if (MessageQueue.IsFatalError(status)) 1826MessageQueue labeledQueue = ResolveQueueFromLabel(path, false); 1857if (MessageQueue.IsFatalError(status)) 1902machineName = MessageQueue.ComputerName; 1913if (MessageQueue.IsFatalError(status)) 1940if (MessageQueue.IsFatalError(status)) 2023public static MessageQueue[] GetPrivateQueuesByMachine(string machineName) 2031if (machineName == "." || (String.Compare(machineName, MessageQueue.ComputerName, true, CultureInfo.InvariantCulture) == 0)) 2038if (MessageQueue.IsFatalError(status)) 2043MessageQueue[] queues = new MessageQueue[len]; 2064public static MessageQueue[] GetPublicQueues() 2077public static MessageQueue[] GetPublicQueues(MessageQueueCriteria criteria) 2089public static MessageQueue[] GetPublicQueuesByCategory(Guid category) 2103public static MessageQueue[] GetPublicQueuesByLabel(string label) 2110private static MessageQueue[] GetPublicQueuesByLabel(string label, bool checkSecurity) 2123public static MessageQueue[] GetPublicQueuesByMachine(string machineName) 2151return new MessageQueue[0]; 2157return new MessageQueue[0]; 2166MessageQueue[] queues = new MessageQueue[objects.Count]; 2266/// available in the queue referenced by the <see cref='System.Messaging.MessageQueue'/> . This call 2282/// available in the queue referenced by the <see cref='System.Messaging.MessageQueue'/> 2384if (MessageQueue.IsFatalError(status)) 2391/// Receives the first message available in the queue referenced by the <see cref='System.Messaging.MessageQueue'/> . This 2404/// Receives the first message available in the queue referenced by the <see cref='System.Messaging.MessageQueue'/> . This 2433/// referenced by the <see cref='System.Messaging.MessageQueue'/> 2456/// referenced by the <see cref='System.Messaging.MessageQueue'/> 2623if (MessageQueue.IsFatalError(status)) 2983while (MessageQueue.IsMemoryError(status)) 3006if (MessageQueue.IsFatalError(status)) 3066while (MessageQueue.IsMemoryError(status)) 3093if (MessageQueue.IsFatalError(status)) 3102/// Refreshes the properties presented by the <see cref='System.Messaging.MessageQueue'/> 3127if (MessageQueue.IsFatalError(status)) 3134/// Sends an object to the queue referenced by this <see cref='System.Messaging.MessageQueue'/> 3147/// Sends an object to the queue referenced by this <see cref='System.Messaging.MessageQueue'/> 3163/// Sends an object to the queue referenced by this <see cref='System.Messaging.MessageQueue'/> 3179/// Sends an object to the queue referenced by this <see cref='System.Messaging.MessageQueue'/>. 3192/// Sends an object to the queue referenced by this <see cref='System.Messaging.MessageQueue'/>. 3208/// Sends an object to the queue referenced by this <see cref='System.Messaging.MessageQueue'/>. 3288if (MessageQueue.IsFatalError(status)) 3295private static MessageQueue ResolveQueueFromLabel(string path, bool throwException) 3297MessageQueue[] queues = GetPublicQueuesByLabel(path.Substring(PREFIX_LABEL.Length), false); 3325machine = MessageQueue.ComputerName; 3328Guid machineId = MessageQueue.GetMachineId(machine); 3676private MessageQueue owner; 3691internal unsafe AsynchronousRequest(MessageQueue owner, uint timeout, CursorHandle cursorHandle, int action, bool useThreadPool, object asyncState, AsyncCallback callback) 3792while (MessageQueue.IsMemoryError(localStatus)) 3824if (MessageQueue.IsFatalError(localStatus)) 3839if (MessageQueue.IsFatalError(status)) 3897if (MessageQueue.IsMemoryError(result)) 3899while (MessageQueue.IsMemoryError(result)) 3923if (!MessageQueue.IsFatalError(result)) 3943if (!MessageQueue.IsFatalError(result)) 4326if (MessageQueue.IsFatalError(status)) 4357if (MessageQueue.IsFatalError(status)) 4392if (MessageQueue.IsFatalError(status)) 4419if (MessageQueue.IsFatalError(status)) 4445if (MessageQueue.IsFatalError(status))
System\Messaging\MessageQueueCriteria.cs (1)
160this.machineId = MessageQueue.GetMachineId(value);
System\Messaging\MessageQueueEnumerator.cs (5)
33private MessageQueue currentMessageQueue; 61public MessageQueue Current 159if (MessageQueue.IsFatalError(status)) 187machineName = MessageQueue.ComputerName + "\\"; 197if (MessageQueue.IsFatalError(status))
System\Messaging\MessageQueueInstaller.cs (28)
22/// utility, installutil.exe, when installing a <see cref='System.Messaging.MessageQueue'/> 61public MessageQueueInstaller(MessageQueue componentToCopy) 216if (!MessageQueue.Msmq3OrNewer) //this feature is unavailable on win2k 225if (!MessageQueue.Msmq3OrNewer) //this feature is unavailable on win2k 252if (!MessageQueue.ValidatePath(value, true)) 341/// <para>Completes the installation process by committing <see cref='System.Messaging.MessageQueue'/> 354MessageQueue queue = new MessageQueue(path); 360/// <para>Copies the property values of a <see cref='System.Messaging.MessageQueue'/> 372MessageQueue queue = component as MessageQueue; 396bool exists = MessageQueue.Exists(path); 398MessageQueue queue = null; 400queue = MessageQueue.Create(Path, Transactional); 418if (MessageQueue.Msmq3OrNewer) //this feature is unavailable on win2k 425MessageQueue.Delete(Path); 426queue = MessageQueue.Create(Path, Transactional); 439if (MessageQueue.Msmq3OrNewer) //this feature is unavailable on win2k 479MessageQueue queue = null; 482if (!MessageQueue.Exists(Path)) 486queue = MessageQueue.Create(Path, (bool)state["Transactional"]); 494MessageQueue.Delete(Path); 495queue = MessageQueue.Create(Path, (bool)state["Transactional"]); 507if (MessageQueue.Msmq3OrNewer) //this feature is unavailable on win2k 517if (MessageQueue.Exists(path)) 518MessageQueue.Delete(path); 555/// Uninstall also deletes the queue associated with the <see cref='System.Messaging.MessageQueue'/>. </para> 564if (MessageQueue.Exists(Path)) 565MessageQueue.Delete(Path);
System\Messaging\MessageQueuePermission.cs (4)
348MessageQueue queue = new MessageQueue(entry.Path); 372IEnumerator messageQueues = MessageQueue.GetMessageQueueEnumerator(criteria, false); 375MessageQueue queue = (MessageQueue)messageQueues.Current;
System\Messaging\MessageQueuePermissionAttribute.cs (1)
107if (value != null && value != MessageQueuePermission.Any && !MessageQueue.ValidatePath(value, false))
System\Messaging\MessageQueuePermissionEntry.cs (1)
27if (path != MessageQueuePermission.Any && !MessageQueue.ValidatePath(path, false))
System\Messaging\MessageQueueTransaction.cs (3)
80if (MessageQueue.IsFatalError(status)) 106if (MessageQueue.IsFatalError(status)) 143if (MessageQueue.IsFatalError(status))
System\Messaging\PeekCompletedEventArgs.cs (3)
16/// <para>Provides data for the <see cref='System.Messaging.MessageQueue.PeekCompleted'/> event. When your asynchronous 24private MessageQueue sender; 28internal PeekCompletedEventArgs(MessageQueue sender, IAsyncResult result)
System\Messaging\PeekCompletedEventHandler.cs (2)
29/// <para>Represents the method that will handle the <see cref='System.Messaging.MessageQueue.PeekCompleted'/> event of a <see cref='System.Messaging.MessageQueue'/>.</para>
System\Messaging\ReceiveCompletedEventArgs.cs (3)
16/// <para>Provides data for the <see cref='System.Messaging.MessageQueue.ReceiveCompleted'/> 23private MessageQueue sender; 27internal ReceiveCompletedEventArgs(MessageQueue sender, IAsyncResult result)
System\Messaging\ReceiveCompletedEventHandler.cs (2)
29/// <para>Represents the method that will handle the <see cref='System.Messaging.MessageQueue.ReceiveCompleted'/> event of a <see cref='System.Messaging.MessageQueue'/>.</para>
System.ServiceModel (6)
System\ServiceModel\Channels\MsmqBindingMonitor.cs (6)
230MessageQueue[] queues = MessageQueue.GetPublicQueuesByMachine(this.host); 241MessageQueue[] queues = MessageQueue.GetPrivateQueuesByMachine(this.host); 270void ProcessFoundQueues(MessageQueue[] queues, Dictionary<string, MatchState> knownQueues, bool isPrivate) 272foreach (MessageQueue queue in queues)