Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-1452: Close Connection in checkMissingQueues

Browse Source 
Resolves https://github.com/spring-projects/spring-amqp/issues/1452

While not a problem with connection factories provided by the framework
(which all ignore `close()`) the code should properly close the connection
after use.

**cherry-pick to 2.4.x, 2.3.x**
This commit is contained in:
Gary Russell
2022-04-20 15:43:16 -04:00
committed by Artem Bilan
parent 59197ca12a
commit 9d49f20893
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java
View File

@@ -554,7 +554,8 @@ public class BlockingQueueConsumer {
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");