From c2e53ed5f1de393fde772ff6acb0b1302c45a0bf Mon Sep 17 00:00:00 2001 From: "Alan.Yu" Date: Mon, 5 Jul 2021 21:56:09 +0800 Subject: [PATCH] Binding queue using existing cosumerChannel --- .../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); } }