23EventQueueState pendingQueueState = new EventQueueState(); 425EventQueueState queueState = new EventQueueState(); 598EventQueueState snapshotState = new EventQueueState(); 718EventQueueState individualPersistedQueueStateValue = new EventQueueState(); 725pendingQueueStateSnapshot = new EventQueueState();

66internal void CopyFrom(EventQueueState copyFromState)

34EventQueueState qState = qService.GetQueueState(this.queueName); 68EventQueueState qState = qService.GetQueueState(this.queueName);

23EventQueueState pendingQueueState = new EventQueueState(); 24Dictionary<IComparable, EventQueueState> persistedQueueStates; 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)); 46private Dictionary<IComparable, EventQueueState> persistedQueueStatesSnapshot = null; 47private EventQueueState pendingQueueStateSnapshot = null; 54this.persistedQueueStates = (Dictionary<IComparable, EventQueueState>)this.rootWorkflowExecutor.RootActivity.GetValue(WorkflowQueuingService.RootPersistedQueueStatesProperty); 57this.persistedQueueStates = new Dictionary<IComparable, EventQueueState>(); 70this.persistedQueueStates = new Dictionary<IComparable, EventQueueState>(); 110EventQueueState queueState = GetEventQueueState(queueName); 179EventQueueState qState = GetQueue(queueName); 211EventQueueState qState = GetQueue(queueName); 246EventQueueState queueState = GetEventQueueState(queueName); 269EventQueueState queueState = GetEventQueueState(queueName); 280internal EventQueueState GetQueueState(IComparable eventType) 307private bool QueueAsynchronousEvent(IComparable queueName, EventQueueState qState) 312q.Enqueue(new KeyValuePair<IComparable, EventQueueState>(queueName, qState)); 324EventQueueState queueState = null; 337KeyValuePair<IComparable, EventQueueState> pair = (KeyValuePair<IComparable, EventQueueState>)q.Dequeue(); 345EventQueueState qState = service.GetQueue(pair.Key); 356internal void NotifyAsynchronousSubscribers(IComparable queueName, EventQueueState qState, int numberOfNotification) 382foreach (EventQueueState queueState in this.persistedQueueStates.Values) 397private EventQueueState GetEventQueueState(IComparable queueName) 399EventQueueState queueState = GetQueue(queueName); 425EventQueueState queueState = new EventQueueState(); 432internal EventQueueState GetQueue(IComparable queueID) 434EventQueueState queue; 466private void ApplyChangesFrom(EventQueueState srcPendingQueueState, Dictionary<IComparable, EventQueueState> srcPersistedQueueStates) 470Dictionary<IComparable, EventQueueState> modifiedItems = new Dictionary<IComparable, EventQueueState>(); 472foreach (KeyValuePair<IComparable, EventQueueState> mergeItem in srcPersistedQueueStates) 480EventQueueState oldvalue = this.persistedQueueStates[mergeItem.Key]; 496foreach (KeyValuePair<IComparable, EventQueueState> modifiedItem in modifiedItems) 508private void NotifyExternalSubscribers(IComparable queueName, EventQueueState qState, Object eventInstance) 514private void NotifySynchronousSubscribers(IComparable queueName, EventQueueState qState, Object eventInstance) 528private EventQueueState MarkQueueDirtyIfTransactional(IComparable queueName) 537EventQueueState queueState = GetQueue(queueName); 578EventQueueState qState = GetQueue(queueName); 592EventQueueState queueState = this.rootQueuingService.MarkQueueDirtyIfTransactional(queueName); 598EventQueueState snapshotState = new EventQueueState(); 633EventQueueState qState = GetQueue(queueName); 650EventQueueState qState = GetQueue(queueName); 715persistedQueueStatesSnapshot = new Dictionary<IComparable, EventQueueState>(); 716foreach (KeyValuePair<IComparable, EventQueueState> kv in persistedQueueStates) 718EventQueueState individualPersistedQueueStateValue = new EventQueueState();