From 24949c2bafaa332a4c30ea2faf63954f5e5abe6f Mon Sep 17 00:00:00 2001 From: espent1004 Date: Wed, 5 Feb 2020 22:17:46 +0100 Subject: [PATCH] Changing implementation to not get the actualEventBus if it is system-wide event. --- .../EventBusRabbitMQ/MultiEventBusRabbitMQ.cs | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/src/BuildingBlocks/EventBus/EventBusRabbitMQ/MultiEventBusRabbitMQ.cs b/src/BuildingBlocks/EventBus/EventBusRabbitMQ/MultiEventBusRabbitMQ.cs index f386f9b41..f2c9fd0c5 100644 --- a/src/BuildingBlocks/EventBus/EventBusRabbitMQ/MultiEventBusRabbitMQ.cs +++ b/src/BuildingBlocks/EventBus/EventBusRabbitMQ/MultiEventBusRabbitMQ.cs @@ -30,12 +30,15 @@ namespace Microsoft.eShopOnContainers.BuildingBlocks.EventBusRabbitMQ eventBus.Publish(@event); }); } - - //TODO requires ALL events to have tenantId set! - _tenants.TryGetValue(@event.TenantId, out String tenantName); - var actualEventBus = _eventBuses.Find(e => e.GetVHost().Equals(tenantName)); + else + { + //TODO requires ALL events to have tenantId set! + _tenants.TryGetValue(@event.TenantId, out String tenantName); + var actualEventBus = _eventBuses.Find(e => e.GetVHost().Equals(tenantName)); + + actualEventBus.Publish(@event); + } - actualEventBus.Publish(@event); } public void Subscribe() where T : IntegrationEvent where TH : IIntegrationEventHandler