21this.qService = qService;

32lock (qService.SyncRoot) 34EventQueueState qState = qService.GetQueueState(this.queueName); 35ActivityExecutorDelegateInfo<QueueEventArgs> subscriber = new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity); 40qService.NotifyAsynchronousSubscribers(this.queueName, qState, qState.Messages.Count); 45lock (qService.SyncRoot) 47ActivityExecutorDelegateInfo<QueueEventArgs> subscriber = new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity); 48bool removed = qService.GetQueueState(this.queueName).AsynchronousListeners.Remove(subscriber); 66lock (qService.SyncRoot) 68EventQueueState qState = qService.GetQueueState(this.queueName); 69ActivityExecutorDelegateInfo<QueueEventArgs> subscriber = new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity); 78qService.NotifyAsynchronousSubscribers(this.queueName, qState, qState.Messages.Count); 86lock (qService.SyncRoot) 88ActivityExecutorDelegateInfo<QueueEventArgs> subscriber = new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity); 89bool removed = qService.GetQueueState(this.queueName).AsynchronousListeners.Remove(subscriber); 104lock (qService.SyncRoot) 106qService.GetQueueState(this.queueName).SynchronousListeners.Add(new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity)); 114lock (qService.SyncRoot) 116qService.GetQueueState(this.queueName).SynchronousListeners.Remove(new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity)); 125lock (qService.SyncRoot) 127qService.GetQueueState(this.queueName).SynchronousListeners.Add(new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity)); 135lock (qService.SyncRoot) 137qService.GetQueueState(this.queueName).SynchronousListeners.Remove(new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity)); 153return this.qService; 159lock (qService.SyncRoot) 161qService.EnqueueEvent(this.queueName, item); 167lock (qService.SyncRoot) 169object message = qService.Peek(this.queueName); 171return qService.DequeueEvent(this.queueName); 177lock (qService.SyncRoot) 179object message = qService.Peek(this.queueName); 189lock (qService.SyncRoot) 191return this.qService.GetQueueState(this.queueName).Messages.Count; 200lock (qService.SyncRoot) 202return this.qService.GetQueueState(this.queueName).Enabled; 207lock (qService.SyncRoot) 209this.qService.GetQueueState(this.queueName).Enabled = value;