晚上 自定义 事件名称

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))
                 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);
                     typeDict.TryAdd(type, type.FullName);
 
 
                     if (!codeDict.TryAdd(type.FullName, type))
                     if (!codeDict.TryAdd(type.FullName, type))

src/Pole.EventBus.Rabbitmq/Core/RabbitEventBus.cs

@@ -68,7 +68,7 @@ namespace Pole.EventBus.RabbitMQ
                     observerUnit.GetBatchEventHandler())
                     observerUnit.GetBatchEventHandler())
                 {
                 {
                     EventBus = this,
                     EventBus = this,
-                    QueueInfo = new QueueInfo { RoutingKey = RoutePrefix, Queue = $"{RoutePrefix}_{queueNameSuffix}" },
+                    QueueInfo = new QueueInfo { RoutingKey = string.Empty, Queue = $"{RoutePrefix}_{queueNameSuffix}" },
                     Config = ConsumerConfig
                     Config = ConsumerConfig
                 };
                 };
                 Consumers.Add(consumer);
                 Consumers.Add(consumer);