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);