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)