2 writes to qService
System.Workflow.Runtime (2)
WorkflowExecutor.cs (2)
198
qService
= new WorkflowQueuingService(this);
313
this.
qService
= new WorkflowQueuingService(this);
20 references to qService
System.Workflow.Runtime (20)
WorkflowExecutor.cs (20)
691
lock (
qService
.SyncRoot)
693
if (
qService
.Exists(sub.QueueName))
695
qService
.EnqueueEvent(sub.QueueName, sub.SubscriptionId);
1040
this.
qService
.MoveAllMessagesToPendingQueue();
1189
qService
.PrePersist();
1194
qService
.PostPersist(true);
1216
qService
.ProcessesQueuedAsynchronousEvents();
1240
qService
.EnqueueEvent(queueName, item);
1245
if (
qService
.SafeEnqueueEvent(queueName, item))
1312
qService
.EnqueueEvent(queueName, item);
1334
lock (
qService
.SyncRoot)
1336
IEnumerable<IComparable> names =
qService
.QueueNames;
1341
WorkflowQueue queue =
qService
.GetWorkflowQueue(name);
1344
Queue items =
qService
.GetQueue(name).Messages;
1345
List<ActivityExecutorDelegateInfo<QueueEventArgs>> listeners =
qService
.GetQueue(name).AsynchronousListeners;
1708
this.
qService
.MoveAllMessagesToPendingQueue();
2112
transactionalProperties.LocalQueuingService = new WorkflowQueuingService(this.
qService
);
2234
qService
.PostPersist(false);
2253
qService
.PostPersist(false);
3089
queuingService = this.
qService
; // root Q service