22 references to Messages
System.Workflow.Runtime (22)
EventQueueState.cs (1)
68this.deliveredMessages = new Queue(copyFromState.Messages);
WorkflowExecutor.cs (1)
1344Queue items = qService.GetQueue(name).Messages;
WorkflowQueue.cs (3)
40qService.NotifyAsynchronousSubscribers(this.queueName, qState, qState.Messages.Count); 78qService.NotifyAsynchronousSubscribers(this.queueName, qState, qState.Messages.Count); 191return this.qService.GetQueueState(this.queueName).Messages.Count;
WorkflowQueuingService.cs (17)
53this.rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.PendingMessagesProperty, this.pendingQueueState.Messages); 69this.rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.PendingMessagesProperty, this.pendingQueueState.Messages); 112Queue queue = queueState.Messages; 113Queue pendingQueue = this.pendingQueueState.Messages; 186qState.Messages.Enqueue(item); 218qState.Messages.Enqueue(item); 247if (queueState.Messages.Count != 0) 248return queueState.Messages.Peek(); 270if (queueState.Messages.Count != 0) 271return queueState.Messages.Dequeue(); 311Queue q = GetQueue(pendingNotification).Messages; 334Queue q = GetQueue(pendingNotification).Messages; 381Queue pendingQueue = this.pendingQueueState.Messages; 384Queue queue = queueState.Messages; 640qState.Messages.Enqueue(item); 657qState.Messages.Enqueue(item); 693rootWorkflowExecutor.RootActivity.SetValue(WorkflowQueuingService.PendingMessagesProperty, pendingQueueStateSnapshot.Messages);