1 instantiation of MsmqSubqueueLockingQueue
System.ServiceModel (1)
System\ServiceModel\Channels\Msmq.cs (1)
97
return new
MsmqSubqueueLockingQueue
(receiver.MsmqReceiveParameters.AddressTranslator.UriToFormatName(receiver.ListenUri), receiver.ListenUri.Host, UnsafeNativeMethods.MQ_RECEIVE_ACCESS);
7 references to MsmqSubqueueLockingQueue
System.ServiceModel (7)
System\ServiceModel\Channels\Msmq4PoisonHandler.cs (2)
56
Fx.Assert(this.receiver.Queue is
MsmqSubqueueLockingQueue
, "Queue must be MsmqSubqueueLockingQueue");
57
this.lockQueueForReceive = ((
MsmqSubqueueLockingQueue
)this.receiver.Queue).LockQueueForReceive;
System\ServiceModel\Channels\MsmqSubqueueLockingQueue.cs (5)
38
this.validHostName =
MsmqSubqueueLockingQueue
.TryGetHostName(formatName, out hostname);
46
this.lockQueueName = this.formatName + ";" +
MsmqSubqueueLockingQueue
.GenerateLockQueueName();
65
return
MsmqSubqueueLockingQueue
.LockSubqueuePrefix + lockGuid.Substring(lockGuid.Length - 8, 8);
117
this.lockQueueName = this.formatName + ";" +
MsmqSubqueueLockingQueue
.GenerateLockQueueName();
274
if (subqueueName.StartsWith(
MsmqSubqueueLockingQueue
.LockSubqueuePrefix, StringComparison.OrdinalIgnoreCase))