diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java
index 263ac54604..d0f08d9222 100644
--- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java
+++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java
@@ -554,7 +554,8 @@ private void checkMissingQueues() {
 					Connection connection = null; // NOSONAR - RabbitUtils
 					Channel channelForCheck = null;
 					try {
-						channelForCheck = this.connectionFactory.createConnection().createChannel(false);
+						connection = this.connectionFactory.createConnection();
+						channelForCheck = connection.createChannel(false);
 						channelForCheck.queueDeclarePassive(queueToCheck);
 						if (logger.isInfoEnabled()) {
 							logger.info("Queue '" + queueToCheck + "' is now available");