Changed method name

viktor-shevchenko-ideals · viktor-shevchenko-ideals · commit 4cf59daf2d41 · 2022-08-14T15:00:02.000+03:00
diff --git a/src/WorkflowCore/Services/BackgroundTasks/WorkflowConsumer.cs b/src/WorkflowCore/Services/BackgroundTasks/WorkflowConsumer.cs
@@ -68,7 +68,7 @@ protected override async Task ProcessItem(string itemId, CancellationToken cance
                 {
                     foreach (var sub in result.Subscriptions)
                     {
-                        await SubscribeEvent(sub, _persistenceStore, cancellationToken);
+                        await TryProcessSubscription(sub, _persistenceStore, cancellationToken);
                     }
 
                     await _persistenceStore.PersistErrors(result.Errors, cancellationToken);
@@ -98,7 +98,7 @@ await _persistenceStore.ScheduleCommand(new ScheduledCommand()
 
         }
 
-        private async Task SubscribeEvent(EventSubscription subscription, IPersistenceProvider persistenceStore, CancellationToken cancellationToken)
+        private async Task TryProcessSubscription(EventSubscription subscription, IPersistenceProvider persistenceStore, CancellationToken cancellationToken)
         {
             if (subscription.EventName != Event.EventTypeActivity)
             {

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ protected override async Task ProcessItem(string itemId, CancellationToken cance`
`68`	`68`	`{`
`69`	`69`	`foreach (var sub in result.Subscriptions)`
`70`	`70`	`{`
`71`		`- await SubscribeEvent(sub, _persistenceStore, cancellationToken);`
	`71`	`+ await TryProcessSubscription(sub, _persistenceStore, cancellationToken);`
`72`	`72`	`}`
`73`	`73`
`74`	`74`	`await _persistenceStore.PersistErrors(result.Errors, cancellationToken);`
`@@ -98,7 +98,7 @@ await _persistenceStore.ScheduleCommand(new ScheduledCommand()`
`98`	`98`
`99`	`99`	`}`
`100`	`100`
`101`		`- private async Task SubscribeEvent(EventSubscription subscription, IPersistenceProvider persistenceStore, CancellationToken cancellationToken)`
	`101`	`+ private async Task TryProcessSubscription(EventSubscription subscription, IPersistenceProvider persistenceStore, CancellationToken cancellationToken)`
`102`	`102`	`{`
`103`	`103`	`if (subscription.EventName != Event.EventTypeActivity)`
`104`	`104`	`{`