1 write to owner
System.Messaging (1)
System\Messaging\MessageQueue.cs (1)
3693this.owner = owner;
17 references to owner
System.Messaging (17)
System\Messaging\MessageQueue.cs (17)
3787this.message = new Message(owner.MessageReadPropertyFilter); 3791localStatus = this.owner.StaleSafeReceiveMessage(this.timeout, this.action, this.message.Lock(), overlappedPointer, this.onMessageReceived, this.cursorHandle, IntPtr.Zero); 3801localStatus = this.owner.StaleSafeReceiveMessage(this.timeout, this.action, this.message.Lock(), overlappedPointer, this.onMessageReceived, this.cursorHandle, IntPtr.Zero); 3815if (!this.owner.useThreadPool) 3816this.owner.OutstandingAsyncRequests.Remove(this); 3842if (this.owner.formatter != null) 3843this.message.Formatter = (IMessageFormatter)this.owner.formatter.Clone(); 3914result = this.owner.StaleSafeReceiveMessage(this.timeout, this.action, this.message.Lock(), overlappedPointer, this.onMessageReceived, this.cursorHandle, IntPtr.Zero); 3930if (this.owner.IsCashedInfoInvalidOnReceive(result)) 3932this.owner.MQInfo.Close(); 3936result = this.owner.StaleSafeReceiveMessage(this.timeout, this.action, this.message.Lock(), overlappedPointer, this.onMessageReceived, this.cursorHandle, IntPtr.Zero); 3965if (this.owner.SynchronizingObject != null && 3966this.owner.SynchronizingObject.InvokeRequired) 3968this.owner.SynchronizingObject.BeginInvoke(this.callback, new object[] { this }); 3982if (!this.owner.useThreadPool) 3984Debug.Assert(this.owner.OutstandingAsyncRequests.Contains(this)); 3985this.owner.OutstandingAsyncRequests.Remove(this);