Add OverrideExchangeName()

YarinOmesi · Sep 2, 2023 · bb58af8 · bb58af8
1 parent 50d3e34
commit bb58af8
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/...ports/MassTransit.RabbitMqTransport/Configuration/IRabbitMqReceiveEndpointConfigurator.cs b/...ports/MassTransit.RabbitMqTransport/Configuration/IRabbitMqReceiveEndpointConfigurator.cs
@@ -61,5 +61,11 @@ void Bind<T>(Action<IRabbitMqExchangeBindingConfigurator> callback = null)
         /// </summary>
         /// <param name="consumerTag">The consumer tag to use for this receive endpoint.</param>
         void OverrideConsumerTag(string consumerTag);
+
+        /// <summary>
+        /// By default, the exchange and queue name would be same
+        /// </summary>
+        /// <param name="exchangeName">The new exchange name for this endpoint</param>
+        void OverrideExchangeName(string exchangeName);
     }
 }
diff --git a/...RabbitMqTransport/RabbitMqTransport/Configuration/RabbitMqReceiveEndpointConfiguration.cs b/...RabbitMqTransport/RabbitMqTransport/Configuration/RabbitMqReceiveEndpointConfiguration.cs
@@ -252,6 +252,11 @@ public void OverrideConsumerTag(string consumerTag)
             _settings.ConsumerTag = consumerTag;
         }
 
+        public void OverrideExchangeName(string exchangeName)
+        {
+            _settings.ExchangeName = exchangeName;
+        }
+
         RabbitMqReceiveEndpointContext CreateRabbitMqReceiveEndpointContext()
         {
             var builder = new RabbitMqReceiveEndpointBuilder(_hostConfiguration, this);