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

AMQP-109: catch and log exception during stop

Browse Source
This commit is contained in:
Dave Syer
2011-03-14 12:00:13 +00:00
parent c027107cfc
commit f41ee23964
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -45,7 +45,7 @@ public class BlockingQueueConsumer {
private final int prefetchCount;
private final boolean transactional;
private final Channel channel;
private final AtomicBoolean cancelled = new AtomicBoolean(false);
@@ -54,7 +54,8 @@ public class BlockingQueueConsumer {
private final AcknowledgeMode acknowledgeMode;
public BlockingQueueConsumer(Channel channel, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, String... queues) {
public BlockingQueueConsumer(Channel channel, AcknowledgeMode acknowledgeMode, boolean transactional,
int prefetchCount, String... queues) {
this.channel = channel;
this.acknowledgeMode = acknowledgeMode;
this.transactional = transactional;
@@ -154,7 +155,16 @@ public class BlockingQueueConsumer {
public void stop() {
cancelled.set(true);
logger.debug("Closing Rabbit Channel: " + channel);
RabbitUtils.closeMessageConsumer(consumer.getChannel(), consumer.getConsumerTag(), transactional);
try {
RabbitUtils.closeMessageConsumer(consumer.getChannel(), consumer.getConsumerTag(), transactional);
} catch (AmqpException e) {
if (logger.isDebugEnabled()) {
logger.info("Could not close message consumer on shutdown", e);
} else {
logger.info("Could not close message consumer on shutdown (" + e.getClass() + "): " + e.getMessage());
}
}
// This one never throws exceptions...
RabbitUtils.closeChannel(channel);
}