|
@ -1,4 +1,4 @@ |
|
|
using Microsoft.Extensions.DependencyInjection; |
|
|
|
|
|
|
|
|
using Microsoft.Extensions.DependencyInjection; |
|
|
|
|
|
|
|
|
namespace Microsoft.eShopOnContainers.BuildingBlocks.EventBusServiceBus; |
|
|
namespace Microsoft.eShopOnContainers.BuildingBlocks.EventBusServiceBus; |
|
|
|
|
|
|
|
@ -12,7 +12,6 @@ public class EventBusServiceBus : IEventBus, IAsyncDisposable |
|
|
private readonly string _subscriptionName; |
|
|
private readonly string _subscriptionName; |
|
|
private readonly ServiceBusSender _sender; |
|
|
private readonly ServiceBusSender _sender; |
|
|
private readonly ServiceBusProcessor _processor; |
|
|
private readonly ServiceBusProcessor _processor; |
|
|
private readonly string AUTOFAC_SCOPE_NAME = "eshop_event_bus"; |
|
|
|
|
|
private const string INTEGRATION_EVENT_SUFFIX = "IntegrationEvent"; |
|
|
private const string INTEGRATION_EVENT_SUFFIX = "IntegrationEvent"; |
|
|
|
|
|
|
|
|
public EventBusServiceBus(IServiceBusPersisterConnection serviceBusPersisterConnection, |
|
|
public EventBusServiceBus(IServiceBusPersisterConnection serviceBusPersisterConnection, |
|
@ -198,4 +197,4 @@ public class EventBusServiceBus : IEventBus, IAsyncDisposable |
|
|
_subsManager.Clear(); |
|
|
_subsManager.Clear(); |
|
|
await _processor.CloseAsync(); |
|
|
await _processor.CloseAsync(); |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
} |