@@ -13,20 +13,16 @@ namespace WorkflowCore.Services
13
13
{
14
14
public class ActivityController : IActivityController
15
15
{
16
- private readonly IWorkflowRepository _persistenceStore ;
17
16
private readonly ISubscriptionRepository _subscriptionRepository ;
18
17
private readonly IDistributedLockProvider _lockProvider ;
19
18
private readonly IDateTimeProvider _dateTimeProvider ;
20
- private readonly IQueueProvider _queueProvider ;
21
19
private readonly IWorkflowController _workflowController ;
22
20
23
- public ActivityController ( ISubscriptionRepository subscriptionRepository , IWorkflowRepository persistenceStore , IWorkflowController workflowController , IDateTimeProvider dateTimeProvider , IDistributedLockProvider lockProvider , IQueueProvider queueProvider )
21
+ public ActivityController ( ISubscriptionRepository subscriptionRepository , IWorkflowController workflowController , IDateTimeProvider dateTimeProvider , IDistributedLockProvider lockProvider )
24
22
{
25
- _persistenceStore = persistenceStore ;
26
23
_subscriptionRepository = subscriptionRepository ;
27
24
_dateTimeProvider = dateTimeProvider ;
28
25
_lockProvider = lockProvider ;
29
- _queueProvider = queueProvider ;
30
26
_workflowController = workflowController ;
31
27
}
32
28
@@ -108,28 +104,6 @@ private async Task SubmitActivityResult(string token, ActivityResult result)
108
104
result . SubscriptionId = sub . Id ;
109
105
110
106
await _workflowController . PublishEvent ( sub . EventName , sub . EventKey , result ) ;
111
-
112
- //if (!await _lockProvider.AcquireLock(sub.WorkflowId, CancellationToken.None))
113
- // throw new WorkflowLockedException();
114
-
115
- //try
116
- //{
117
- // var workflow = await _persistenceStore.GetWorkflowInstance(sub.WorkflowId);
118
- // var pointer = workflow.ExecutionPointers.Single(p => p.Id == sub.ExecutionPointerId);
119
-
120
- // pointer.EventData = result;
121
- // pointer.EventPublished = true;
122
- // pointer.Active = true;
123
-
124
- // workflow.NextExecution = 0;
125
- // await _persistenceStore.PersistWorkflow(workflow);
126
- // await _subscriptionRepository.TerminateSubscription(sub.Id);
127
- //}
128
- //finally
129
- //{
130
- // await _lockProvider.ReleaseLock(sub.WorkflowId);
131
- // await _queueProvider.QueueWork(sub.WorkflowId, QueueType.Workflow);
132
- //}
133
107
}
134
108
135
109
class Token
0 commit comments