This commit is contained in:
espent1004 2019-11-19 22:39:48 +01:00
parent 2be714234b
commit 89c5addfe8
5 changed files with 8 additions and 5 deletions

View File

@ -10,9 +10,11 @@ namespace Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Events
{ {
TenantId = tenantId; TenantId = tenantId;
this.@event = @event; this.@event = @event;
eventType = @event.GetType().Name;
} }
public int TenantId { get; set; } public int TenantId { get; set; }
public IntegrationEvent @event { get; set; } public IntegrationEvent @event { get; set; }
public String eventType { get; set; }
} }
} }

View File

@ -257,7 +257,6 @@ namespace Microsoft.eShopOnContainers.BuildingBlocks.EventBusRabbitMQ
return channel; return channel;
} }
private async Task ProcessEvent(string eventName, string message) private async Task ProcessEvent(string eventName, string message)
{ {
_logger.LogWarning("Processing RabbitMQ event: {EventName}", eventName); _logger.LogWarning("Processing RabbitMQ event: {EventName}", eventName);

View File

@ -1,6 +1,7 @@
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.Extensions.Logging; using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using Ordering.API.Application.IntegrationEvents.Events; using Ordering.API.Application.IntegrationEvents.Events;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
@ -39,6 +40,8 @@ namespace TenantACustomisations.IntegrationEvents.EventHandling
} }
break; break;
default: default:
integrationEvent.CheckForCustomisation = false;
_eventBus.Publish(integrationEvent);
break; break;
} }
} }

View File

@ -6,7 +6,7 @@ using Serilog;
using System; using System;
using System.IO; using System.IO;
namespace Microsoft.eShopOnContainers.Services.Ordering.API namespace Microsoft.eShopOnContainers.Services.TenantACustomisations
{ {
public class Program public class Program
{ {

View File

@ -1,9 +1,8 @@
using System; using Ordering.API.Application.IntegrationEvents.Events;
using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Events;
using Ordering.API.Application.IntegrationEvents.Events;
namespace TenantACustomisations.Services namespace TenantACustomisations.Services
{ {