👌 Default RabbitMQ Options.

Author: catcherwong

src/EasyCaching.Bus.RabbitMQ/Configurations/RabbitMQBusOptions.cs

@@ -11,7 +11,7 @@ public class RabbitMQBusOptions : BaseRabbitMQOptions
         /// Gets or sets the route key.
         /// </summary>
         /// <value>The route key.</value>
-        public string RouteKey { get; set; } = "easycaching.subscriber.*";
+        public string RouteKey { get; set; } = "rmq.queue.undurable.easycaching.subscriber.*";
 
         /// <summary>
         /// Gets or sets the name of the queue.

src/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs

@@ -42,7 +42,7 @@ public class DefaultRabbitMQBus : IEasyCachingBus
         /// <summary>
         /// The identifier.
         /// </summary>
-        private readonly string _Id;
+        private readonly string _busId;
 
         /// <summary>
         /// Initializes a new instance of the <see cref="T:EasyCaching.Bus.RabbitMQ.DefaultRabbitMQBus"/> class.
@@ -74,7 +74,7 @@ IPooledObjectPolicy<IConnection> _objectPolicy
 
             _pubConnectionPool = new DefaultObjectPool<IConnection>(_objectPolicy);
 
-            _Id = Guid.NewGuid().ToString("N");
+            _busId = Guid.NewGuid().ToString("N");
         }
 
         /// <summary>
@@ -144,7 +144,7 @@ public void Subscribe(string topic, Action<EasyCachingMessage> action)
             var queueName = string.Empty;
             if(string.IsNullOrWhiteSpace(_options.QueueName))
             {
-                queueName = $"easycaching.subscriber.{_Id}";
+                queueName = $"rmq.queue.undurable.easycaching.subscriber.{_busId}";
             }
             else
             {

src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs

@@ -25,7 +25,7 @@ public class BaseRabbitMQOptions
         /// <summary>
         /// Topic exchange name when declare a topic exchange.
         /// </summary>
-        public string TopicExchangeName { get; set; } = "easycaching.exchange";
+        public string TopicExchangeName { get; set; } = "rmq.exchange.topic.easycaching";
 
         /// <summary>
         /// Timeout setting for connection attempts (in milliseconds).