Fix of DelayedExchangeScheduler: do not create extra queue (#1032)

Author: Pliner

RabbitMQ/Dockerfile

@@ -0,0 +1,4 @@
+FROM rabbitmq:3.8-management
+RUN apt-get update && apt-get install -y wget
+RUN wget -O $RABBITMQ_HOME/plugins/rabbitmq_delayed_message_exchange-3.8.0.ez https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/download/v3.8.0/rabbitmq_delayed_message_exchange-3.8.0.ez
+RUN rabbitmq-plugins enable --offline rabbitmq_delayed_message_exchange

Source/EasyNetQ/Scheduling/DelayedExchangeScheduler.cs

@@ -82,12 +82,9 @@ private async Task FuturePublishInternalAsync<T>(TimeSpan messageDelay, T messag
 
             var exchangeName = conventions.ExchangeNamingConvention(typeof (T));
             var futureExchangeName = exchangeName + "_delayed";
-            var queueName = conventions.QueueNamingConvention(typeof (T), null);
             var futureExchange = await advancedBus.ExchangeDeclareAsync(futureExchangeName, ExchangeType.Direct, delayed: true).ConfigureAwait(false);
             var exchange = await advancedBus.ExchangeDeclareAsync(exchangeName, ExchangeType.Topic).ConfigureAwait(false);
             await advancedBus.BindAsync(futureExchange, exchange, topic).ConfigureAwait(false);
-            var queue = await advancedBus.QueueDeclareAsync(queueName).ConfigureAwait(false);
-            await advancedBus.BindAsync(exchange, queue, topic).ConfigureAwait(false);
             var easyNetQMessage = new Message<T>(message)
             {
                 Properties =
@@ -107,12 +104,9 @@ private void FuturePublishInternal<T>(TimeSpan messageDelay, T message, string t
 
             var exchangeName = conventions.ExchangeNamingConvention(typeof(T));
             var futureExchangeName = exchangeName + "_delayed";
-            var queueName = conventions.QueueNamingConvention(typeof(T), null);
             var futureExchange = advancedBus.ExchangeDeclare(futureExchangeName, ExchangeType.Direct, delayed: true);
             var exchange = advancedBus.ExchangeDeclare(exchangeName, ExchangeType.Topic);
             advancedBus.Bind(futureExchange, exchange, topic);
-            var queue = advancedBus.QueueDeclare(queueName);
-            advancedBus.Bind(exchange, queue, topic);
             var easyNetQMessage = new Message<T>(message)
             {
                 Properties =
@@ -125,4 +119,4 @@ private void FuturePublishInternal<T>(TimeSpan messageDelay, T message, string t
         }
 
     }
-}
+}

docker-compose.yaml

@@ -1,7 +1,8 @@
 version: '3.4'
 services:
   rabbitmq:
-    image: rabbitmq:3-management
+    build:
+      context: ./RabbitMQ/
     ports:
       - "15672:15672"
       - "5672:5672"