diff --git a/src/Services/SagaManager/SagaManager/IntegrationEvents/ISagaManagingIntegrationEventService.cs b/src/Services/SagaManager/SagaManager/IntegrationEvents/ISagaManagingIntegrationEventService.cs index 570618b91..26d97e682 100644 --- a/src/Services/SagaManager/SagaManager/IntegrationEvents/ISagaManagingIntegrationEventService.cs +++ b/src/Services/SagaManager/SagaManager/IntegrationEvents/ISagaManagingIntegrationEventService.cs @@ -4,6 +4,6 @@ public interface ISagaManagingIntegrationEventService { - void PublishThroughEventBusAsync(IntegrationEvent evt); + void PublishThroughEventBus(IntegrationEvent evt); } } \ No newline at end of file diff --git a/src/Services/SagaManager/SagaManager/IntegrationEvents/SagaManagingIntegrationEventService.cs b/src/Services/SagaManager/SagaManager/IntegrationEvents/SagaManagingIntegrationEventService.cs index 825977a25..5052e3b27 100644 --- a/src/Services/SagaManager/SagaManager/IntegrationEvents/SagaManagingIntegrationEventService.cs +++ b/src/Services/SagaManager/SagaManager/IntegrationEvents/SagaManagingIntegrationEventService.cs @@ -1,12 +1,7 @@ namespace SagaManager.IntegrationEvents { - using System.Data.Common; - using System.Threading.Tasks; - using Microsoft.EntityFrameworkCore; using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Abstractions; using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Events; - using Microsoft.eShopOnContainers.BuildingBlocks.IntegrationEventLogEF.Services; - using Microsoft.eShopOnContainers.Services.Ordering.Infrastructure; using System; public class SagaManagingIntegrationEventService : ISagaManagingIntegrationEventService @@ -18,7 +13,7 @@ _eventBus = eventBus ?? throw new ArgumentNullException(nameof(eventBus)); } - public void PublishThroughEventBusAsync(IntegrationEvent evt) + public void PublishThroughEventBus(IntegrationEvent evt) { _eventBus.Publish(evt); } diff --git a/src/Services/SagaManager/SagaManager/Program.cs b/src/Services/SagaManager/SagaManager/Program.cs index 832aa0145..6f181be2f 100644 --- a/src/Services/SagaManager/SagaManager/Program.cs +++ b/src/Services/SagaManager/SagaManager/Program.cs @@ -16,6 +16,7 @@ namespace SagaManager using Microsoft.Extensions.Options; using RabbitMQ.Client; using Services; + public class Program { diff --git a/src/Services/SagaManager/SagaManager/Services/SagaManagerService.cs b/src/Services/SagaManager/SagaManager/Services/SagaManagerService.cs index 88c186d93..50b06ba98 100644 --- a/src/Services/SagaManager/SagaManager/Services/SagaManagerService.cs +++ b/src/Services/SagaManager/SagaManager/Services/SagaManagerService.cs @@ -66,7 +66,7 @@ namespace SagaManager.Services var confirmGracePeriodEvent = new ConfirmGracePeriodCommandMsg(orderId); // Publish through the Event Bus - _sagaManagingIntegrationEventService.PublishThroughEventBusAsync(confirmGracePeriodEvent); + _sagaManagingIntegrationEventService.PublishThroughEventBus(confirmGracePeriodEvent); } } } \ No newline at end of file