79 references to QueueEventArgs
System.Workflow.Activities (34)
Delay.cs (5)
29public sealed class DelayActivity : Activity, IEventActivity, IActivityEventListener<QueueEventArgs> 273void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs e) 298void IEventActivity.Subscribe(ActivityExecutionContext parentContext, IActivityEventListener<QueueEventArgs> parentEventHandler) 329void IEventActivity.Unsubscribe(ActivityExecutionContext parentContext, IActivityEventListener<QueueEventArgs> parentEventHandler)
EventHandlers.cs (3)
348private sealed class EventHandlerEventActivitySubscriber : IActivityEventListener<QueueEventArgs> 386void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs e)
EventSinkActivity.cs (5)
27public class HandleExternalEventActivity : Activity, IEventActivity, IPropertyValueProvider, IActivityEventListener<QueueEventArgs>, IDynamicPropertyTypeProvider 347void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs e) 383void IEventActivity.Subscribe(ActivityExecutionContext parentContext, IActivityEventListener<QueueEventArgs> parentEventHandler) 393void IEventActivity.Unsubscribe(ActivityExecutionContext parentContext, IActivityEventListener<QueueEventArgs> parentEventHandler)
Interfaces.cs (2)
46void Subscribe(ActivityExecutionContext parentContext, IActivityEventListener<QueueEventArgs> parentEventHandler); 47void Unsubscribe(ActivityExecutionContext parentContext, IActivityEventListener<QueueEventArgs> parentEventHandler);
Listen.cs (3)
241private sealed class ListenEventActivitySubscriber : IActivityEventListener<QueueEventArgs> 250void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs e)
LocalService\CorrelationService.cs (3)
60internal static bool Subscribe(IServiceProvider context, Activity activity, Type interfaceType, string methodName, IActivityEventListener<QueueEventArgs> eventListener, Guid instanceId) 98internal static bool Unsubscribe(IServiceProvider context, Activity activity, Type interfaceType, string methodName, IActivityEventListener<QueueEventArgs> eventListener) 249private static void SubscribeForCorrelationTokenInvalidation(Activity activity, Type interfaceType, string followermethodName, IActivityEventListener<QueueEventArgs> eventListener, Guid instanceId)
LocalService\CorrelationTokenInvalidatedHandler.cs (2)
16IActivityEventListener<QueueEventArgs> eventHandler; 25internal CorrelationTokenInvalidatedHandler(Type interfaceType, string operation, IActivityEventListener<QueueEventArgs> eventHandler, Guid instanceId)
LocalService\FollowerQueueCreator.cs (3)
19internal sealed class FollowerQueueCreator : IActivityEventListener<QueueEventArgs> 45void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs args)
StateMachineSubscription.cs (3)
22internal abstract class StateMachineSubscription : IActivityEventListener<QueueEventArgs> 46void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs e)
WebServiceReceive.cs (5)
32public sealed class WebServiceInputActivity : Activity, IEventActivity, IPropertyValueProvider, IActivityEventListener<QueueEventArgs>, IDynamicPropertyTypeProvider 366void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs e) 384void IEventActivity.Subscribe(ActivityExecutionContext parentContext, IActivityEventListener<QueueEventArgs> parentEventHandler) 394void IEventActivity.Unsubscribe(ActivityExecutionContext parentContext, IActivityEventListener<QueueEventArgs> parentEventHandler)
System.Workflow.Runtime (30)
EventQueueState.cs (6)
19List<ActivityExecutorDelegateInfo<QueueEventArgs>> synchronousListeners; 20List<ActivityExecutorDelegateInfo<QueueEventArgs>> asynchronousListeners; 33this.synchronousListeners = new List<ActivityExecutorDelegateInfo<QueueEventArgs>>(); 34this.asynchronousListeners = new List<ActivityExecutorDelegateInfo<QueueEventArgs>>(); 41internal List<ActivityExecutorDelegateInfo<QueueEventArgs>> AsynchronousListeners 45internal List<ActivityExecutorDelegateInfo<QueueEventArgs>> SynchronousListeners
WorkflowExecutor.cs (2)
1345List<ActivityExecutorDelegateInfo<QueueEventArgs>> listeners = qService.GetQueue(name).AsynchronousListeners; 1347foreach (ActivityExecutorDelegateInfo<QueueEventArgs> l in listeners)
WorkflowQueue.cs (19)
25public event EventHandler<QueueEventArgs> QueueItemAvailable 35ActivityExecutorDelegateInfo<QueueEventArgs> subscriber = new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity); 47ActivityExecutorDelegateInfo<QueueEventArgs> subscriber = new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity); 57public void RegisterForQueueItemAvailable(IActivityEventListener<QueueEventArgs> eventListener) 61public void RegisterForQueueItemAvailable(IActivityEventListener<QueueEventArgs> eventListener, string subscriberQualifiedName) 69ActivityExecutorDelegateInfo<QueueEventArgs> subscriber = new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity); 81public void UnregisterForQueueItemAvailable(IActivityEventListener<QueueEventArgs> eventListener) 88ActivityExecutorDelegateInfo<QueueEventArgs> subscriber = new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity); 97public event EventHandler<QueueEventArgs> QueueItemArrived 106qService.GetQueueState(this.queueName).SynchronousListeners.Add(new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity)); 116qService.GetQueueState(this.queueName).SynchronousListeners.Remove(new ActivityExecutorDelegateInfo<QueueEventArgs>(value, qService.CallingActivity)); 120public void RegisterForQueueItemArrived(IActivityEventListener<QueueEventArgs> eventListener) 127qService.GetQueueState(this.queueName).SynchronousListeners.Add(new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity)); 130public void UnregisterForQueueItemArrived(IActivityEventListener<QueueEventArgs> eventListener) 137qService.GetQueueState(this.queueName).SynchronousListeners.Remove(new ActivityExecutorDelegateInfo<QueueEventArgs>(eventListener, qService.CallingActivity));
WorkflowQueuingService.cs (3)
360QueueEventArgs args = new QueueEventArgs(queueName); 363foreach (ActivityExecutorDelegateInfo<QueueEventArgs> subscriber in qState.AsynchronousListeners) 516QueueEventArgs args = new QueueEventArgs(queueName);
System.WorkflowServices (15)
System\Workflow\Activities\ReceiveActivity.cs (15)
40IActivityEventListener<QueueEventArgs>, 111private IActivityEventListener<QueueEventArgs> securityShim; 112private IActivityEventListener<QueueEventArgs> validationShim; 419void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, 420QueueEventArgs e) 535IActivityEventListener<QueueEventArgs> parentEventHandler) 581IActivityEventListener<QueueEventArgs> parentEventHandler) 1536class SecurityShim : IActivityEventListener<QueueEventArgs>, IDisposable 1550void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs queueEventArgs) 1592class ValidationShim : IActivityEventListener<QueueEventArgs>, IDisposable 1594IActivityEventListener<QueueEventArgs> activityEventListener; 1597internal ValidationShim(ReceiveActivity receiveActivity, IActivityEventListener<QueueEventArgs> activityEventListener) 1613void IActivityEventListener<QueueEventArgs>.OnEvent(object sender, QueueEventArgs queueEventArgs)