From 5c57b8c3f9b705c5be0890416d9005fca36f6ffe Mon Sep 17 00:00:00 2001 From: AlanYu Date: Wed, 7 Jul 2021 15:34:25 +0800 Subject: [PATCH] Binding queue using existing cosumerChannel (#1716) Co-authored-by: Alan.Yu --- .../EventBus/EventBusRabbitMQ/EventBusRabbitMQ.cs | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/src/BuildingBlocks/EventBus/EventBusRabbitMQ/EventBusRabbitMQ.cs b/src/BuildingBlocks/EventBus/EventBusRabbitMQ/EventBusRabbitMQ.cs index 415da4283..935b10ec8 100644 --- 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); } }