diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Consumers/RestartServiceBusQueuesConsumer.cs b/src/activities/Elsa.Activities.AzureServiceBus/Consumers/RestartServiceBusQueuesConsumer.cs index ffa63c517..ed8e70888 100644 --- a/src/activities/Elsa.Activities.AzureServiceBus/Consumers/RestartServiceBusQueuesConsumer.cs +++ b/src/activities/Elsa.Activities.AzureServiceBus/Consumers/RestartServiceBusQueuesConsumer.cs @@ -5,11 +5,12 @@ using Rebus.Handlers; namespace Elsa.Activities.AzureServiceBus.Consumers { - public class RestartServiceBusQueuesConsumer : IHandleMessages, IHandleMessages + public class RestartServiceBusQueuesConsumer : IHandleMessages, IHandleMessages, IHandleMessages { private readonly IServiceBusQueuesStarter _serviceBusQueuesStarter; public RestartServiceBusQueuesConsumer(IServiceBusQueuesStarter serviceBusQueuesStarter) => _serviceBusQueuesStarter = serviceBusQueuesStarter; public Task Handle(WorkflowDefinitionPublished message) => _serviceBusQueuesStarter.CreateWorkersAsync(); public Task Handle(WorkflowDefinitionRetracted message) => _serviceBusQueuesStarter.CreateWorkersAsync(); + public Task Handle(WorkflowDefinitionDeleted message) => _serviceBusQueuesStarter.CreateWorkersAsync(); } } \ No newline at end of file diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Consumers/RestartServiceBusTopicsConsumer.cs b/src/activities/Elsa.Activities.AzureServiceBus/Consumers/RestartServiceBusTopicsConsumer.cs index 94196cb31..bbc26639f 100644 --- a/src/activities/Elsa.Activities.AzureServiceBus/Consumers/RestartServiceBusTopicsConsumer.cs +++ b/src/activities/Elsa.Activities.AzureServiceBus/Consumers/RestartServiceBusTopicsConsumer.cs @@ -5,11 +5,12 @@ using Rebus.Handlers; namespace Elsa.Activities.AzureServiceBus.Consumers { - public class RestartServiceBusTopicsConsumer : IHandleMessages, IHandleMessages + public class RestartServiceBusTopicsConsumer : IHandleMessages, IHandleMessages, IHandleMessages { private readonly IServiceBusTopicsStarter _serviceBusTopicsStarter; public RestartServiceBusTopicsConsumer(IServiceBusTopicsStarter serviceBusTopicsStarter) => _serviceBusTopicsStarter = serviceBusTopicsStarter; public Task Handle(WorkflowDefinitionPublished message) => _serviceBusTopicsStarter.CreateWorkersAsync(); public Task Handle(WorkflowDefinitionRetracted message) => _serviceBusTopicsStarter.CreateWorkersAsync(); + public Task Handle(WorkflowDefinitionDeleted message) => _serviceBusTopicsStarter.CreateWorkersAsync(); } } \ No newline at end of file diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Extensions/ServiceCollectionExtensions.cs b/src/activities/Elsa.Activities.AzureServiceBus/Extensions/ServiceCollectionExtensions.cs index 407050352..057e0dfa9 100644 --- a/src/activities/Elsa.Activities.AzureServiceBus/Extensions/ServiceCollectionExtensions.cs +++ b/src/activities/Elsa.Activities.AzureServiceBus/Extensions/ServiceCollectionExtensions.cs @@ -43,6 +43,7 @@ namespace Elsa.Activities.AzureServiceBus.Extensions options.AddPubSubConsumer("WorkflowDefinitionEvents"); options.AddPubSubConsumer("WorkflowDefinitionEvents"); + options.AddPubSubConsumer("WorkflowDefinitionEvents"); options.AddPubSubConsumer("WorkflowDefinitionEvents"); options.AddPubSubConsumer("WorkflowDefinitionEvents");