From a3cf84d8cc3bc9e382336de6854d5517fafc71e0 Mon Sep 17 00:00:00 2001 From: John Baker Date: Tue, 10 May 2016 18:12:42 -0500 Subject: [PATCH] (#83) - IsInitialized for a queue was looking at the list of initialed exchanges instead of initialized queues. --- src/RawRabbit/Common/TopologyProvider.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/RawRabbit/Common/TopologyProvider.cs b/src/RawRabbit/Common/TopologyProvider.cs index 8f275dd1..d816aa93 100644 --- a/src/RawRabbit/Common/TopologyProvider.cs +++ b/src/RawRabbit/Common/TopologyProvider.cs @@ -133,7 +133,7 @@ public bool IsInitialized(ExchangeConfiguration exchange) public bool IsInitialized(QueueConfiguration queue) { - return queue.IsDirectReplyTo() || _initExchanges.Contains(queue.FullQueueName); + return queue.IsDirectReplyTo() || _initQueues.Contains(queue.FullQueueName); } private void BindQueueToExchange(ScheduledBindQueueTask bind)