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

AMQP-171: fix recovery on connection close - need to clear delivery tags more carefully

Browse Source
This commit is contained in:
Dave Syer
2011-06-04 10:23:20 +01:00
parent fbd2b64c83
commit 01afdd6abf
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -227,6 +227,8 @@ public class BlockingQueueConsumer {
logger.debug("Received shutdown signal for consumer tag=" + consumerTag, sig);
}
shutdown = sig;
// The delivery tags will be invalid if the channel shuts down
deliveryTags.clear();
}
@Override

2
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerRecoveryCachingConnectionIntegrationTests.java
View File

@@ -53,7 +53,7 @@ public class MessageListenerRecoveryCachingConnectionIntegrationTests {
private SimpleMessageListenerContainer container;
@Rule
public Log4jLevelAdjuster logLevels = new Log4jLevelAdjuster(Level.INFO, RabbitTemplate.class,
public Log4jLevelAdjuster logLevels = new Log4jLevelAdjuster(Level.DEBUG, RabbitTemplate.class,
SimpleMessageListenerContainer.class, BlockingQueueConsumer.class, CachingConnectionFactory.class);
@Rule