1 write to queueName
System.Workflow.Runtime (1)
WorkflowQueue.cs (1)
22
this.
queueName
= queueName;
18 references to queueName
System.Workflow.Runtime (18)
WorkflowQueue.cs (18)
34
EventQueueState qState = qService.GetQueueState(this.
queueName
);
40
qService.NotifyAsynchronousSubscribers(this.
queueName
, qState, qState.Messages.Count);
48
bool removed = qService.GetQueueState(this.
queueName
).AsynchronousListeners.Remove(subscriber);
68
EventQueueState qState = qService.GetQueueState(this.
queueName
);
78
qService.NotifyAsynchronousSubscribers(this.
queueName
, qState, qState.Messages.Count);
89
bool removed = qService.GetQueueState(this.
queueName
).AsynchronousListeners.Remove(subscriber);
106
qService.GetQueueState(this.
queueName
).SynchronousListeners.Add(new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity));
116
qService.GetQueueState(this.
queueName
).SynchronousListeners.Remove(new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity));
127
qService.GetQueueState(this.
queueName
).SynchronousListeners.Add(new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity));
137
qService.GetQueueState(this.
queueName
).SynchronousListeners.Remove(new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity));
145
return this.
queueName
;
161
qService.EnqueueEvent(this.
queueName
, item);
169
object message = qService.Peek(this.
queueName
);
171
return qService.DequeueEvent(this.
queueName
);
179
object message = qService.Peek(this.
queueName
);
191
return this.qService.GetQueueState(this.
queueName
).Messages.Count;
202
return this.qService.GetQueueState(this.
queueName
).Enabled;
209
this.qService.GetQueueState(this.
queueName
).Enabled = value;