From 4ffee37938088b8997db96dd64ca1bc8330659b8 Mon Sep 17 00:00:00 2001 From: dingsongjie Date: Mon, 24 Feb 2020 14:30:47 +0800 Subject: [PATCH] 晚上 自定义 事件名称 --- src/Pole.Core/Serialization/EventTypeFinder.cs | 6 ++++++ src/Pole.EventBus.Rabbitmq/Core/RabbitEventBus.cs | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/src/Pole.Core/Serialization/EventTypeFinder.cs b/src/Pole.Core/Serialization/EventTypeFinder.cs index 440f1dd..a5d71f0 100644 --- a/src/Pole.Core/Serialization/EventTypeFinder.cs +++ b/src/Pole.Core/Serialization/EventTypeFinder.cs @@ -24,6 +24,12 @@ namespace Pole.Core.Serialization { foreach (var type in assembly.GetTypes().Where(m => baseEventType.IsAssignableFrom(m)&&!m.IsAbstract)) { + var eventCode = type.FullName; + var eventAttribute = type.GetCustomAttributes(typeof(EventAttribute),false).FirstOrDefault(); + if (eventAttribute is EventAttribute attribute ) + { + eventCode = attribute.EventName; + } typeDict.TryAdd(type, type.FullName); if (!codeDict.TryAdd(type.FullName, type)) diff --git a/src/Pole.EventBus.Rabbitmq/Core/RabbitEventBus.cs b/src/Pole.EventBus.Rabbitmq/Core/RabbitEventBus.cs index 8a69213..0e3a9e8 100644 --- a/src/Pole.EventBus.Rabbitmq/Core/RabbitEventBus.cs +++ b/src/Pole.EventBus.Rabbitmq/Core/RabbitEventBus.cs @@ -68,7 +68,7 @@ namespace Pole.EventBus.RabbitMQ observerUnit.GetBatchEventHandler()) { EventBus = this, - QueueInfo = new QueueInfo { RoutingKey = RoutePrefix, Queue = $"{RoutePrefix}_{queueNameSuffix}" }, + QueueInfo = new QueueInfo { RoutingKey = string.Empty, Queue = $"{RoutePrefix}_{queueNameSuffix}" }, Config = ConsumerConfig }; Consumers.Add(consumer); -- libgit2 0.25.0