Skip to content

Commit f32b358

Browse files
garyrussellartembilan
authored andcommitted
AMQP-800: LocalizedQueueConnectionFactory Fix
JIRA: https://jira.spring.io/browse/AMQP-800 The `LocalizedQueueConnectionFactory` incorrectly destroyed the injected default connection factory. It should only destroy factories that it creates. **cherry-pick to 1.7.x**
1 parent fecd0ba commit f32b358

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/LocalizedQueueConnectionFactory.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -366,9 +366,6 @@ public void destroy() throws Exception {
366366
((DisposableBean) connectionFactory).destroy();
367367
}
368368
}
369-
if (this.defaultConnectionFactory instanceof DisposableBean) {
370-
((DisposableBean) this.defaultConnectionFactory).destroy();
371-
}
372369
}
373370

374371
}

0 commit comments

Comments
 (0)