1 instantiation of MsmqReceiveContext
System.ServiceModel (1)
System\ServiceModel\Channels\MsmqReceiveContextLockManager.cs (1)
53MsmqReceiveContext receiveContext = new MsmqReceiveContext(lookupId, expiryTime, this);
27 references to MsmqReceiveContext
System.ServiceModel (27)
System\ServiceModel\Channels\MsmqInputChannelBase.cs (2)
174message.Properties[MsmqReceiveContext.Name] = this.receiveContextManager.CreateMsmqReceiveContext(msmqMessage.LookupId.Value); 242message.Properties[MsmqReceiveContext.Name] = this.receiveContextManager.CreateMsmqReceiveContext(msmqMessage.LookupId.Value);
System\ServiceModel\Channels\MsmqReceiveContext.cs (4)
121MsmqReceiveContext receiver; 127ReceiveContextAsyncResult(MsmqReceiveContext receiver, TimeSpan timeout, AsyncCallback callback, object state, Action<object> target) 141public static IAsyncResult CreateComplete(MsmqReceiveContext receiver, TimeSpan timeout, AsyncCallback callback, object state) 150public static IAsyncResult CreateAbandon(MsmqReceiveContext receiver, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\MsmqReceiveContextLockManager.cs (21)
17Dictionary<long, MsmqReceiveContext> messageExpiryMap; 18Dictionary<Guid, List<MsmqReceiveContext>> transMessages; 33this.messageExpiryMap = new Dictionary<long, MsmqReceiveContext>(); 34this.transMessages = new Dictionary<Guid, List<MsmqReceiveContext>>(); 49public MsmqReceiveContext CreateMsmqReceiveContext(long lookupId) 53MsmqReceiveContext receiveContext = new MsmqReceiveContext(lookupId, expiryTime, this); 68public void DeleteMessage(MsmqReceiveContext receiveContext, TimeSpan timeout) 79MsmqReceiveContext entry = this.messageExpiryMap[lookupId]; 91List<MsmqReceiveContext> transMsgs; 94transMsgs = new List<MsmqReceiveContext>(); 121public void UnlockMessage(MsmqReceiveContext receiveContext, TimeSpan timeout) 135bool ReceiveContextExists(MsmqReceiveContext receiveContext) 139MsmqReceiveContext receiveContextFromMap = null; 158List<MsmqReceiveContext> toRemove; 161foreach (MsmqReceiveContext entry in toRemove) 187List<MsmqReceiveContext> expiredLockList = new List<MsmqReceiveContext>(); 190foreach (KeyValuePair<long, MsmqReceiveContext> msgEntry in this.messageExpiryMap) 199foreach (MsmqReceiveContext entry in expiredLockList) 220MsmqReceiveContext receiveContext = (MsmqReceiveContext)sender;