Browse Source

Remove async sufix from PublishThroughEventBus method name

pull/223/head
Christian Arenas 7 years ago
parent
commit
83dadc878b
4 changed files with 4 additions and 8 deletions
  1. +1
    -1
      src/Services/SagaManager/SagaManager/IntegrationEvents/ISagaManagingIntegrationEventService.cs
  2. +1
    -6
      src/Services/SagaManager/SagaManager/IntegrationEvents/SagaManagingIntegrationEventService.cs
  3. +1
    -0
      src/Services/SagaManager/SagaManager/Program.cs
  4. +1
    -1
      src/Services/SagaManager/SagaManager/Services/SagaManagerService.cs

+ 1
- 1
src/Services/SagaManager/SagaManager/IntegrationEvents/ISagaManagingIntegrationEventService.cs View File

@ -4,6 +4,6 @@
public interface ISagaManagingIntegrationEventService public interface ISagaManagingIntegrationEventService
{ {
void PublishThroughEventBusAsync(IntegrationEvent evt);
void PublishThroughEventBus(IntegrationEvent evt);
} }
} }

+ 1
- 6
src/Services/SagaManager/SagaManager/IntegrationEvents/SagaManagingIntegrationEventService.cs View File

@ -1,12 +1,7 @@
namespace SagaManager.IntegrationEvents 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.Abstractions;
using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Events; using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Events;
using Microsoft.eShopOnContainers.BuildingBlocks.IntegrationEventLogEF.Services;
using Microsoft.eShopOnContainers.Services.Ordering.Infrastructure;
using System; using System;
public class SagaManagingIntegrationEventService : ISagaManagingIntegrationEventService public class SagaManagingIntegrationEventService : ISagaManagingIntegrationEventService
@ -18,7 +13,7 @@
_eventBus = eventBus ?? throw new ArgumentNullException(nameof(eventBus)); _eventBus = eventBus ?? throw new ArgumentNullException(nameof(eventBus));
} }
public void PublishThroughEventBusAsync(IntegrationEvent evt)
public void PublishThroughEventBus(IntegrationEvent evt)
{ {
_eventBus.Publish(evt); _eventBus.Publish(evt);
} }


+ 1
- 0
src/Services/SagaManager/SagaManager/Program.cs View File

@ -16,6 +16,7 @@ namespace SagaManager
using Microsoft.Extensions.Options; using Microsoft.Extensions.Options;
using RabbitMQ.Client; using RabbitMQ.Client;
using Services; using Services;
public class Program public class Program
{ {


+ 1
- 1
src/Services/SagaManager/SagaManager/Services/SagaManagerService.cs View File

@ -66,7 +66,7 @@ namespace SagaManager.Services
var confirmGracePeriodEvent = new ConfirmGracePeriodCommandMsg(orderId); var confirmGracePeriodEvent = new ConfirmGracePeriodCommandMsg(orderId);
// Publish through the Event Bus // Publish through the Event Bus
_sagaManagingIntegrationEventService.PublishThroughEventBusAsync(confirmGracePeriodEvent);
_sagaManagingIntegrationEventService.PublishThroughEventBus(confirmGracePeriodEvent);
} }
} }
} }

Loading…
Cancel
Save