2 instantiations of WorkflowExecutor
System.Workflow.Runtime (2)
WorkflowRuntime.cs (1)
491executor = new WorkflowExecutor(key);
WorkflowStateRollbackService.cs (1)
96WorkflowExecutor newWorkflowExecutor = new WorkflowExecutor(Guid.Empty); // use a dummy guid while swapping executors
247 references to WorkflowExecutor
System.Workflow.Runtime (247)
AmbientEnvironment.cs (3)
122return (IWorkBatch)currentActivity.GetValue(WorkflowExecutor.TransientBatchProperty); 134return ((Guid)ContextActivityUtils.RootContextActivity(currentActivity).GetValue(WorkflowExecutor.WorkflowInstanceIdProperty)); 153TransactionalProperties transactionalProperties = (TransactionalProperties)currentActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty);
ContextActivityUtils.cs (1)
55workflowExecutor = (IWorkflowCoreRuntime)rootActivity.GetValue(WorkflowExecutor.WorkflowExecutorProperty);
CreationContext.cs (2)
36internal WorkflowExecutor InvokerExecutor; 42internal CreationContext(Type type, WorkflowExecutor invokerExec, string invokeActivityID, Dictionary<string, object> args)
DebugEngine\DebugController.cs (13)
417WorkflowExecutor executor = instance.GetWorkflowResourceUNSAFE(); 572WorkflowExecutor executor = instance.GetWorkflowResourceUNSAFE(); 651private void OnInstanceEvent(object sender, WorkflowExecutor.WorkflowExecutionEventArgs e) 656InstanceCompleted(sender, new WorkflowEventArgs(((WorkflowExecutor)sender).WorkflowInstance)); 659InstanceTerminated(sender, new WorkflowEventArgs(((WorkflowExecutor)sender).WorkflowInstance)); 662InstanceUnloaded(sender, new WorkflowEventArgs(((WorkflowExecutor)sender).WorkflowInstance)); 674OnActivityStatusChanged(sender, (WorkflowExecutor.ActivityStatusChangeEventArgs)e); 677OnActivityExecuting(sender, (WorkflowExecutor.ActivityExecutingEventArgs)e); 690LoadExistingInstance(((WorkflowExecutor)sender).WorkflowInstance, true); 692LoadExistingInstance(((WorkflowExecutor)sender).WorkflowInstance, false); 763private void OnActivityExecuting(object sender, WorkflowExecutor.ActivityExecutingEventArgs eventArgs) 788private void OnActivityStatusChanged(object sender, WorkflowExecutor.ActivityStatusChangeEventArgs eventArgs) 886WorkflowExecutor executor = instance.GetWorkflowResourceUNSAFE();
Hosting\DefaultWorkflowSchedulerService.cs (1)
338if (WorkflowExecutor.IsIrrecoverableException(e))
Hosting\WorkflowPersistenceService.cs (3)
99return (bool)rootActivity.GetValue(WorkflowExecutor.IsBlockedProperty); 103return (string)rootActivity.GetValue(WorkflowExecutor.SuspendOrTerminateInfoProperty); 107return (WorkflowStatus)rootActivity.GetValue(WorkflowExecutor.WorkflowStatusProperty);
Lock.cs (4)
257private WorkflowExecutor workflowExec; 259internal SchedulerLockGuard(InstanceLock il, WorkflowExecutor w) 265private static void FireEvents(List<SchedulerLockGuardInfo> eventList, WorkflowExecutor workflowExec) 302internal static void Exit(InstanceLock il, WorkflowExecutor w)
PerformanceCounterManager.cs (11)
274private void Notify(PerformanceCounterAction action, WorkflowExecutor executor) 313private void NotifyCounter(PerformanceCounterAction action, PerformanceCounterStatement statement, WorkflowExecutor executor) 342if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 345WorkflowExecutor exec = (WorkflowExecutor)sender; 347exec.WorkflowExecutionEvent += new EventHandler<WorkflowExecutor.WorkflowExecutionEventArgs>(WorkflowExecutionEvent); 350private void WorkflowExecutionEvent(object sender, WorkflowExecutor.WorkflowExecutionEventArgs e) 355if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 356throw new ArgumentException(String.Format(CultureInfo.CurrentCulture, ExecutionStringManager.InvalidArgumentType, "sender", typeof(WorkflowExecutor).ToString())); 358WorkflowExecutor exec = (WorkflowExecutor)sender;
RTTrackingProfile.cs (1)
245internal bool TryTrackUserEvent(Activity activity, string keyName, object argument, WorkflowExecutor exec, UserTrackingRecord record)
Scheduler.cs (6)
26WorkflowExecutor rootWorkflowExecutor; 39public Scheduler(WorkflowExecutor rootExec, bool canRun) 73protected WorkflowExecutor RootWorkflowExecutor 158transactionalProperties = (TransactionalProperties)atomicActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty); 162if (!WorkflowExecutor.CheckAndProcessTransactionAborted(transactionalProperties)) 190if (WorkflowExecutor.IsIrrecoverableException(e))
System\Activities\Statements\Interop.cs (5)
364activityInstance.SetValue(WorkflowExecutor.WorkflowInstanceIdProperty, context.WorkflowInstanceId); 397if (WorkflowExecutor.IsIrrecoverableException(exception) || !this.persistOnClose.Get(context)) 432if (WorkflowExecutor.IsIrrecoverableException(exception) || !this.persistOnClose.Get(context)) 538if (WorkflowExecutor.IsIrrecoverableException(exception) || !this.persistOnClose.Get(context)) 836if (WorkflowExecutor.IsIrrecoverableException(exception) || !this.persistOnClose.Get(context))
System\Activities\Statements\InteropEnvironment.cs (1)
202if (WorkflowExecutor.IsIrrecoverableException(this.uncaughtException))
System\Activities\Statements\InteropExecutor.cs (9)
239TransactionalProperties transactionalProperties = (TransactionalProperties)this.currentAtomicActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty); 257TransactionalProperties transactionalProperties = (TransactionalProperties)this.currentAtomicActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty); 461this.rootActivity.SetValue(WorkflowExecutor.WorkflowExecutorProperty, this); 571atomicActivity.SetValue(WorkflowExecutor.TransactionalPropertiesProperty, transactionProperties); 651transactionalProperties = (TransactionalProperties)activity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty); 777TransactionalProperties transactionalProperties = (TransactionalProperties)atomicActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty); 797TransactionalProperties transactionalProperties = (TransactionalProperties)atomicActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty); 983transactionalProperties = (TransactionalProperties)atomicActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty); 998if (WorkflowExecutor.IsIrrecoverableException(e))
Tracking.cs (61)
103if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 106WorkflowExecutor exec = (WorkflowExecutor)sender; 109exec.WorkflowExecutionEvent += new EventHandler<WorkflowExecutor.WorkflowExecutionEventArgs>(WorkflowExecutionEvent); 111TrackingListenerBroker listenerBroker = (TrackingListenerBroker)exec.RootActivity.GetValue(WorkflowExecutor.TrackingListenerBrokerProperty); 177exec.RootActivity.SetValue(WorkflowExecutor.TrackingListenerBrokerProperty, listener.Broker); 184exec.RootActivity.SetValue(WorkflowExecutor.TrackingListenerBrokerProperty, new TrackingListenerBroker()); 189exec.WorkflowExecutionEvent += new EventHandler<WorkflowExecutor.WorkflowExecutionEventArgs>(listener.WorkflowExecutionEvent); 194void WorkflowExecutionEvent(object sender, WorkflowExecutor.WorkflowExecutionEventArgs e) 204WorkflowExecutor exec = (WorkflowExecutor)sender; 250internal TrackingListener GetTrackingListener(Activity sked, WorkflowExecutor skedExec) 265internal TrackingListener GetTrackingListener(Activity sked, WorkflowExecutor skedExec, TrackingListenerBroker broker) 297internal void ReloadProfiles(WorkflowExecutor exec) 330internal void ReloadProfiles(WorkflowExecutor exec, Guid instanceId, ref TrackingListenerBroker broker, ref List<TrackingChannelWrapper> channels) 427private TrackingListener GetListener(Activity sked, WorkflowExecutor skedExec, TrackingListenerBroker broker) 448private List<TrackingChannelWrapper> GetChannels(Activity schedule, WorkflowExecutor exec, Guid instanceID, Type workflowType, ref TrackingListenerBroker broker) 466Debug.Assert(exec is WorkflowExecutor, "Executor is not WorkflowExecutor"); 468TrackingListenerBroker trackingListenerBroker = (TrackingListenerBroker)exec.RootActivity.GetValue(WorkflowExecutor.TrackingListenerBrokerProperty); 575internal TrackingListener(TrackingListenerFactory factory, Activity sked, WorkflowExecutor exec, List<TrackingChannelWrapper> channels, TrackingListenerBroker broker, bool load) 598internal void ReloadProfiles(WorkflowExecutor exec, Guid instanceId) 608internal void ActivityStatusChange(object sender, WorkflowExecutor.ActivityStatusChangeEventArgs e) 615if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 621WorkflowExecutor exec = (WorkflowExecutor)sender; 658internal void UserTrackPoint(object sender, WorkflowExecutor.UserTrackPointEventArgs e) 660if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 663WorkflowExecutor exec = (WorkflowExecutor)sender; 681internal void WorkflowExecutionEvent(object sender, WorkflowExecutor.WorkflowExecutionEventArgs e) 686WorkflowExecutor exec = sender as WorkflowExecutor; 735UserTrackPoint(exec, (WorkflowExecutor.UserTrackPointEventArgs)e); 738ActivityStatusChange(exec, (WorkflowExecutor.ActivityStatusChangeEventArgs)e); 741DynamicUpdateBegin(exec, (WorkflowExecutor.DynamicUpdateEventArgs)e); 744DynamicUpdateRollback(exec, (WorkflowExecutor.DynamicUpdateEventArgs)e); 747DynamicUpdateCommit(exec, (WorkflowExecutor.DynamicUpdateEventArgs)e); 754internal void DynamicUpdateBegin(object sender, WorkflowExecutor.DynamicUpdateEventArgs e) 759if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 762WorkflowExecutor exec = (WorkflowExecutor)sender; 780internal void DynamicUpdateRollback(object sender, WorkflowExecutor.DynamicUpdateEventArgs e) 785if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 788WorkflowExecutor exec = (WorkflowExecutor)sender; 796internal void DynamicUpdateCommit(object sender, WorkflowExecutor.DynamicUpdateEventArgs e) 801if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 804WorkflowExecutor exec = (WorkflowExecutor)sender; 827private void NotifyChannels(TrackingWorkflowEvent evt, WorkflowExecutor.WorkflowExecutionEventArgs e, WorkflowExecutor exec) 838args = new TrackingWorkflowSuspendedEventArgs(((WorkflowExecutor.WorkflowExecutionSuspendingEventArgs)e).Error); 841WorkflowExecutor.WorkflowExecutionTerminatingEventArgs wtea = (WorkflowExecutor.WorkflowExecutionTerminatingEventArgs)e; 848WorkflowExecutor.WorkflowExecutionExceptionEventArgs weea = (WorkflowExecutor.WorkflowExecutionExceptionEventArgs)e; 864private void GetContext(Activity activity, WorkflowExecutor exec, out Guid contextGuid, out Guid parentContextGuid) 880private void MakeProfilesPrivate(WorkflowExecutor exec) 893private bool SubscriptionRequired(Activity activity, WorkflowExecutor exec) 1615internal RTTrackingProfile GetTrackingProfile(WorkflowExecutor skedExec) 1632internal void MakeProfilePrivate(WorkflowExecutor exec)
WorkBatch.cs (2)
212if (WorkflowExecutor.IsIrrecoverableException(e)) 269if (WorkflowExecutor.IsIrrecoverableException(e))
WorkflowExecutor.cs (42)
28internal readonly static DependencyProperty WorkflowExecutorProperty = DependencyProperty.RegisterAttached("WorkflowExecutor", typeof(IWorkflowCoreRuntime), typeof(WorkflowExecutor), new PropertyMetadata(DependencyPropertyOptions.NonSerialized)); 32internal readonly static DependencyProperty TransientBatchProperty = DependencyProperty.RegisterAttached("TransientBatch", typeof(IWorkBatch), typeof(WorkflowExecutor), new PropertyMetadata(null, DependencyPropertyOptions.NonSerialized, new GetValueOverride(GetTransientBatch), null)); 33internal readonly static DependencyProperty TransactionalPropertiesProperty = DependencyProperty.RegisterAttached("TransactionalProperties", typeof(TransactionalProperties), typeof(WorkflowExecutor), new PropertyMetadata(DependencyPropertyOptions.NonSerialized)); 34internal readonly static DependencyProperty WorkflowInstanceIdProperty = DependencyProperty.RegisterAttached("WorkflowInstanceId", typeof(Guid), typeof(WorkflowExecutor), new PropertyMetadata(Guid.NewGuid())); 35internal readonly static DependencyProperty IsBlockedProperty = DependencyProperty.RegisterAttached("IsBlocked", typeof(bool), typeof(WorkflowExecutor), new PropertyMetadata(false)); 36internal readonly static DependencyProperty WorkflowStatusProperty = DependencyProperty.RegisterAttached("WorkflowStatus", typeof(WorkflowStatus), typeof(WorkflowExecutor), new PropertyMetadata(WorkflowStatus.Created)); 37internal readonly static DependencyProperty SuspendOrTerminateInfoProperty = DependencyProperty.RegisterAttached("SuspendOrTerminateInfo", typeof(string), typeof(WorkflowExecutor)); 40private static DependencyProperty ContextIdProperty = DependencyProperty.RegisterAttached("ContextId", typeof(int), typeof(WorkflowExecutor), new PropertyMetadata(new Int32())); 41private static DependencyProperty TrackingCallingStateProperty = DependencyProperty.RegisterAttached("TrackingCallingState", typeof(TrackingCallingState), typeof(WorkflowExecutor)); 42internal static DependencyProperty TrackingListenerBrokerProperty = DependencyProperty.RegisterAttached("TrackingListenerBroker", typeof(TrackingListenerBroker), typeof(WorkflowExecutor)); 43private static DependencyProperty IsSuspensionRequestedProperty = DependencyProperty.RegisterAttached("IsSuspensionRequested", typeof(bool), typeof(WorkflowExecutor), new PropertyMetadata(false)); 44private static DependencyProperty IsIdleProperty = DependencyProperty.RegisterAttached("IsIdle", typeof(bool), typeof(WorkflowExecutor), new PropertyMetadata(false)); 140internal void Initialize(Activity rootActivity, WorkflowExecutor invokerExec, string invokeActivityID, Guid instanceId, IDictionary<string, object> namedArguments, WorkflowInstance workflowInstance) 146this.rootActivity.SetValue(WorkflowExecutor.ContextIdProperty, 0); 151this.rootActivity.SetValue(WorkflowExecutor.IsIdleProperty, true); 155this.rootActivity.SetValue(WorkflowExecutor.WorkflowExecutorProperty, this); 170TrackingCallingState parentTCS = (TrackingCallingState)invokerExec.rootActivity.GetValue(WorkflowExecutor.TrackingCallingStateProperty); 190this.rootActivity.SetValue(WorkflowExecutor.TrackingCallingStateProperty, trackingCallingState); 282internal void Initialize(Activity rootActivity, WorkflowRuntime runtime, WorkflowExecutor previousWorkflowExecutor) 308this.rootActivity.SetValue(WorkflowExecutor.WorkflowExecutorProperty, this); 394return (TrackingCallingState)this.rootActivity.GetValue(WorkflowExecutor.TrackingCallingStateProperty); 433this.RootActivity.SetValue(WorkflowExecutor.IsIdleProperty, value); 618int conextId = (int)this.rootActivity.GetValue(WorkflowExecutor.ContextIdProperty) + 1; 619this.rootActivity.SetValue(WorkflowExecutor.ContextIdProperty, conextId); 742if (WorkflowExecutor.IsIrrecoverableException(e)) 750this.TerminateOnIdle(WorkflowExecutor.GetNestedExceptionMessage(e)); 851if ((bool)this.rootActivity.GetValue(WorkflowExecutor.IsSuspensionRequestedProperty)) 854this.rootActivity.SetValue(WorkflowExecutor.IsSuspensionRequestedProperty, false); 961if (WorkflowExecutor.IsIrrecoverableException(e)) 976if (this.TerminateOnIdle(WorkflowExecutor.GetNestedExceptionMessage(e))) 1125if (WorkflowExecutor.IsIrrecoverableException(e)) 1307IWorkBatch batch = (IWorkBatch)this.rootActivity.GetValue(WorkflowExecutor.TransientBatchProperty); 1840if (WorkflowExecutor.IsIrrecoverableException(e)) 2886this.TerminateOnIdle(WorkflowExecutor.GetNestedExceptionMessage(e)); 3125private WorkflowExecutor workflowExecutor = null; 3127internal ResetCurrentActivity(WorkflowExecutor workflowExecutor, Activity oldCurrentActivity) 3248internal event EventHandler<WorkflowExecutor.WorkflowExecutionEventArgs> WorkflowExecutionEvent 3642public WorkflowExecutor executor; 3644public ScheduleInfo(WorkflowExecutor executor, bool suppress) 3655public ScheduleWork(WorkflowExecutor executor) 3661public ScheduleWork(WorkflowExecutor executor, bool suppress) 3681static public WorkflowExecutor Executor
WorkflowInstance.cs (19)
28private WorkflowExecutor _deadWorkflow; 57internal WorkflowExecutor DeadWorkflow 74WorkflowExecutor executor = _runtime.Load(this); 94WorkflowExecutor executor = _runtime.Load(this); 114WorkflowExecutor executor = _runtime.Load(this); 145WorkflowExecutor executor = _runtime.Load(this); 171WorkflowExecutor executor = _runtime.Load(this); 212WorkflowExecutor executor = _runtime.Load(this); 249WorkflowExecutor executor = _runtime.Load(this); 278WorkflowExecutor executor = null; 310WorkflowExecutor executor = _runtime.Load(this); 334WorkflowExecutor executor = _runtime.Load(this); 361WorkflowExecutor executor = _runtime.Load(this); 385WorkflowExecutor executor = _runtime.Load(this); 409WorkflowExecutor executor = _runtime.Load(this); 430WorkflowExecutor executor = _runtime.Load(this); 448internal WorkflowExecutor GetWorkflowResourceUNSAFE() 452WorkflowExecutor executor = _runtime.Load(this); 488WorkflowExecutor executor = _runtime.Load(this);
WorkflowQueuingService.cs (2)
686TransactionalProperties transactionalProperties = rootWorkflowExecutor.CurrentAtomicActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty) as TransactionalProperties; 711TransactionalProperties transactionalProperties = this.rootWorkflowExecutor.CurrentAtomicActivity.GetValue(WorkflowExecutor.TransactionalPropertiesProperty) as TransactionalProperties;
WorkflowRuntime.cs (56)
103private FanOutOnKeyDictionary<Guid, WorkflowExecutor> workflowExecutors; 185workflowExecutors = new FanOutOnKeyDictionary<Guid, WorkflowExecutor>((Environment.ProcessorCount * 4) - 1); 260WorkflowExecutor executor = Load(instanceId, null, null); 268foreach (WorkflowExecutor executor in GetWorkflowExecutors()) 416WorkflowExecutor executor = GetWorkflowExecutor(instanceId, context); 464internal WorkflowExecutor Load(WorkflowInstance instance) 469internal WorkflowExecutor Load(Guid key, CreationContext context, WorkflowInstance workflowInstance) 471WorkflowExecutor executor; 472Dictionary<Guid, WorkflowExecutor> executors = workflowExecutors[key]; 507WorkflowExecutor currentRes; 524internal void ReplaceWorkflowExecutor(Guid instanceId, WorkflowExecutor oldWorkflowExecutor, WorkflowExecutor newWorkflowExecutor) 526Dictionary<Guid, WorkflowExecutor> executors = workflowExecutors[instanceId]; 536private Activity InitializeExecutor(Guid instanceId, CreationContext context, WorkflowExecutor executor, WorkflowInstance workflowInstance) 614private void RegisterExecutor(bool isActivation, WorkflowExecutor executor) 631internal void OnIdle(WorkflowExecutor executor) 652private void _unRegister(WorkflowExecutor executor) 663private WorkflowExecutor GetWorkflowExecutor(Guid instanceId, CreationContext context) 669WorkflowExecutor executor = this.Load(instanceId, context, null); 689internal void OnScheduleCompleted(WorkflowExecutor schedule, WorkflowCompletedEventArgs args) 710internal void OnScheduleSuspended(WorkflowExecutor schedule, WorkflowSuspendedEventArgs args) 725internal void OnScheduleTerminated(WorkflowExecutor schedule, WorkflowTerminatedEventArgs args) 744internal void OnScheduleLoaded(WorkflowExecutor schedule) 751internal void OnScheduleAborted(WorkflowExecutor schedule) 757internal void OnScheduleUnloaded(WorkflowExecutor schedule) 764internal void OnScheduleResumed(WorkflowExecutor schedule) 770internal void OnScheduleDynamicallyChanged(WorkflowExecutor schedule) 776internal void OnSchedulePersisted(WorkflowExecutor schedule) 783private void _OnServiceEvent(WorkflowExecutor sched, bool unregister, EventHandler<WorkflowEventArgs> handler) 1183void DynamicUpdateCommit(object sender, WorkflowExecutor.DynamicUpdateEventArgs e) 1188if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 1189throw new ArgumentException(String.Format(CultureInfo.CurrentCulture, ExecutionStringManager.InvalidArgumentType, "sender", typeof(WorkflowExecutor).ToString())); 1191WorkflowExecutor exec = (WorkflowExecutor)sender; 1196internal void WorkflowExecutorCreated(WorkflowExecutor workflowExecutor, bool loaded) 1204workflowExecutor.WorkflowExecutionEvent += new EventHandler<WorkflowExecutor.WorkflowExecutionEventArgs>(WorkflowExecutionEvent); 1207void WorkflowExecutionEvent(object sender, WorkflowExecutor.WorkflowExecutionEventArgs e) 1212if (!typeof(WorkflowExecutor).IsInstanceOfType(sender)) 1215WorkflowExecutor exec = (WorkflowExecutor)sender; 1240WorkflowExecutor.WorkflowExecutionTerminatedEventArgs args = (WorkflowExecutor.WorkflowExecutionTerminatedEventArgs)e; 1252WorkflowExecutor.WorkflowExecutionSuspendedEventArgs sargs = (WorkflowExecutor.WorkflowExecutionSuspendedEventArgs)e; 1262DynamicUpdateCommit(exec, (WorkflowExecutor.DynamicUpdateEventArgs)e); 1269private WorkflowCompletedEventArgs CreateCompletedEventArgs(WorkflowExecutor exec) 1309IList<WorkflowExecutor> executors = GetWorkflowExecutors(); 1312foreach (WorkflowExecutor executor in executors) 1590private IList<WorkflowExecutor> GetWorkflowExecutors() 1596List<WorkflowExecutor> executorsList = new List<WorkflowExecutor>(); 1597foreach (Dictionary<Guid, WorkflowExecutor> executors in workflowExecutors) 1601foreach (WorkflowExecutor executor in executors.Values) 1611private bool TryRemoveWorkflowExecutor(Guid instanceId, WorkflowExecutor executor) 1613Dictionary<Guid, WorkflowExecutor> executors = workflowExecutors[instanceId]; 1616WorkflowExecutor currentRes;
WorkflowStateRollbackService.cs (5)
16WorkflowExecutor workflowExecutor; 33public WorkflowStateRollbackService(WorkflowExecutor workflowExecutor) 93clonedRootActivity.SetValue(WorkflowExecutor.TrackingListenerBrokerProperty, workflowExecutor.RootActivity.GetValue(WorkflowExecutor.TrackingListenerBrokerProperty)); 96WorkflowExecutor newWorkflowExecutor = new WorkflowExecutor(Guid.Empty); // use a dummy guid while swapping executors