Binding queue using existing cosumerChannel

2021-07-05 21:56:09 +08:00 · 2021-07-05 21:56:09 +08:00 · c2e53ed5f1
commit c2e53ed5f1
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);
            }
        }