1 instantiation of WorkflowQueuingService
System.Workflow.Runtime (1)
WorkflowExecutor.cs (1)
2112transactionalProperties.LocalQueuingService = new WorkflowQueuingService(this.qService);
54 references to WorkflowQueuingService
System.Workflow.Runtime (32)
AmbientEnvironment.cs (2)
138internal static WorkflowQueuingService QueuingService 158WorkflowQueuingService queuingService = transactionalProperties.LocalQueuingService;
System\Activities\Statements\InteropExecutor.cs (2)
51WorkflowQueuingService workflowQueuingService; 598if (serviceType == typeof(WorkflowQueuingService))
TransactionalProperties.cs (1)
30internal WorkflowQueuingService LocalQueuingService;
WorkflowExecutor.cs (6)
63private WorkflowQueuingService qService; 105DependencyProperty.RegisterAsKnown(WorkflowQueuingService.LocalPersistedQueueStatesProperty, (byte)63, DependencyProperty.PropertyValidity.Reexecute); 106DependencyProperty.RegisterAsKnown(WorkflowQueuingService.RootPersistedQueueStatesProperty, (byte)64, DependencyProperty.PropertyValidity.Reexecute); 2336WorkflowQueuingService queuingService = transactionalProperties.LocalQueuingService; 3085else if (serviceType == typeof(WorkflowQueuingService)) 3087WorkflowQueuingService queuingService = ServiceEnvironment.QueuingService;
WorkflowQueue.cs (3)
17WorkflowQueuingService qService; 19internal WorkflowQueue(WorkflowQueuingService qService, IComparable queueName) 149public WorkflowQueuingService QueuingService
WorkflowQueuingService.cs (18)
27List<WorkflowQueuingService> messageArrivalEventHandlers; 30WorkflowQueuingService rootQueuingService; 35public readonly static DependencyProperty PendingMessagesProperty = DependencyProperty.RegisterAttached("PendingMessages", typeof(Queue), typeof(WorkflowQueuingService), new PropertyMetadata(DependencyPropertyOptions.NonSerialized)); 38internal static DependencyProperty RootPersistedQueueStatesProperty = DependencyProperty.RegisterAttached("RootPersistedQueueStates", typeof(Dictionary<IComparable, EventQueueState>), typeof(WorkflowQueuingService)); 39internal static DependencyProperty LocalPersistedQueueStatesProperty = DependencyProperty.RegisterAttached("LocalPersistedQueueStates", typeof(Dictionary<IComparable, EventQueueState>), typeof(WorkflowQueuingService)); 53this.rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.PendingMessagesProperty, this.pendingQueueState.Messages); 54this.persistedQueueStates = (Dictionary<IComparable, EventQueueState>)this.rootWorkflowExecutor.RootActivity.GetValue(WorkflowQueuingService.RootPersistedQueueStatesProperty); 58this.rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.RootPersistedQueueStatesProperty, this.persistedQueueStates); 65internal WorkflowQueuingService(WorkflowQueuingService copyFromQueuingService) 69this.rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.PendingMessagesProperty, this.pendingQueueState.Messages); 71this.rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.LocalPersistedQueueStatesProperty, this.persistedQueueStates); 323WorkflowQueuingService qService = messageArrivalEventHandlers[i]; 342WorkflowQueuingService service = this.messageArrivalEventHandlers[i]; 557private void AddMessageArrivedEventHandler(WorkflowQueuingService handler) 562this.messageArrivalEventHandlers = new List<WorkflowQueuingService>(); 567private void RemoveMessageArrivedEventHandler(WorkflowQueuingService handler) 692rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.RootPersistedQueueStatesProperty, persistedQueueStatesSnapshot); 693rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.PendingMessagesProperty, pendingQueueStateSnapshot.Messages);
System.WorkflowServices (22)
System\Workflow\Activities\ReceiveActivity.cs (22)
441WorkflowQueuingService queuingService = executionContext.GetService<WorkflowQueuingService>(); 446typeof(WorkflowQueuingService)))); 593WorkflowQueuingService queuingService = parentContext.GetService<WorkflowQueuingService>(); 598typeof(WorkflowQueuingService)))); 820WorkflowQueuingService queuingService = executionContext.GetService<WorkflowQueuingService>(); 825typeof(WorkflowQueuingService)))); 863WorkflowQueuingService queuingService = executionContext.GetService<WorkflowQueuingService>(); 868typeof(WorkflowQueuingService)))); 996WorkflowQueuingService queuingService = executionContext.GetService<WorkflowQueuingService>(); 1001typeof(WorkflowQueuingService)))); 1277WorkflowQueuingService queuingService = 1278provider.GetService(typeof(WorkflowQueuingService)) as WorkflowQueuingService; 1284typeof(WorkflowQueuingService)))); 1632WorkflowQueuingService queuingService = executionContext.GetService<WorkflowQueuingService>(); 1636new InvalidOperationException(SR2.GetString(SR2.General_MissingService, typeof(WorkflowQueuingService))));