Remove async sufix from PublishThroughEventBus method name

This commit is contained in:
Christian Arenas 2017-05-09 18:33:35 +02:00
parent 9382813905
commit f48d3880a8
4 changed files with 4 additions and 8 deletions

View File

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

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);
} }

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
{ {

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);
} }
} }
} }