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

Fix a ListenerExecutionFailedException usage

Browse Source 
https://build.spring.io/browse/AMQP-AMQP21X-55/
This commit is contained in:
Artem Bilan
2019-07-23 09:48:11 -04:00
parent c9fd46f93d
commit 47e5e17a6c
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/ContainerUtilsTests.java
View File

@@ -24,10 +24,13 @@ import org.junit.jupiter.api.Test;
import org.springframework.amqp.AmqpRejectAndDontRequeueException;
import org.springframework.amqp.ImmediateRequeueAmqpException;
import org.springframework.amqp.rabbit.support.ListenerExecutionFailedException;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException;
/**
* @author Gary Russell
* @author Artem Bilan
*
* @since 2.1.8
*
*/
@@ -36,17 +39,19 @@ public class ContainerUtilsTests {
@Test
void testMustRequeue() {
assertThat(ContainerUtils.shouldRequeue(false,
new ListenerExecutionFailedException("", new ImmediateRequeueAmqpException("requeue")),
new ListenerExecutionFailedException("", new ImmediateRequeueAmqpException("requeue"),
mock(Message.class)),
mock(Log.class)))
.isTrue();
.isTrue();
}
@Test
void testMustNotRequeue() {
assertThat(ContainerUtils.shouldRequeue(true,
new ListenerExecutionFailedException("", new AmqpRejectAndDontRequeueException("no requeue")),
new ListenerExecutionFailedException("", new AmqpRejectAndDontRequeueException("no requeue"),
mock(Message.class)),
mock(Log.class)))
.isFalse();
.isFalse();
}
}