Binding queue using existing cosumerChannel (#1716)

Co-authored-by: Alan.Yu <alan.yu@hidglobal.com>
2021-07-07 15:34:25 +08:00 · 2021-07-07 15:34:25 +08:00 · 5c57b8c3f9
commit 5c57b8c3f9
parent 8bb15ce987
1 changed files with 4 additions and 7 deletions
--- a/src/BuildingBlocks/EventBus/EventBusRabbitMQ/EventBusRabbitMQ.cs
+++ b/src/BuildingBlocks/EventBus/EventBusRabbitMQ/EventBusRabbitMQ.cs
@ -143,13 +143,10 @@ namespace Microsoft.eShopOnContainers.BuildingBlocks.EventBusRabbitMQ
                {
                    _persistentConnection.TryConnect();
                }
-
-                using (var channel = _persistentConnection.CreateModel())
-                {
-                    channel.QueueBind(queue: _queueName,
-                                      exchange: BROKER_NAME,
-                                      routingKey: eventName);
-                }
+ 
+                _consumerChannel.QueueBind(queue: _queueName,
+                                    exchange: BROKER_NAME,
+                                    routingKey: eventName);
            }
        }