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