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

Use basicNack instead of basicReject

Browse Source
This commit is contained in:
Dave Syer
2011-05-10 14:22:22 +01:00
parent 0e8436dec3
commit fbf61b0785
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -629,7 +629,8 @@ public abstract class AbstractMessageListenerContainer extends RabbitAccessor im
if (logger.isDebugEnabled()) {
logger.debug("Rejecting message");
}
channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);
// channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);
channel.basicNack(message.getMessageProperties().getDeliveryTag(), true, true);
}
if (this.isChannelTransacted()) {
// Need to commit the reject (=nack)

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

@@ -52,7 +52,7 @@ public class SimpleMessageListenerContainerIntegrationTests {
private final AcknowledgeMode acknowledgeMode;
@Rule
public Log4jLevelAdjuster logLevels = new Log4jLevelAdjuster(Level.ERROR, RabbitTemplate.class,
public Log4jLevelAdjuster logLevels = new Log4jLevelAdjuster(Level.OFF, RabbitTemplate.class,
SimpleMessageListenerContainer.class, BlockingQueueConsumer.class);
@Rule