From 47e5e17a6cc3f04cddc43c3facf79cbce7e8581d Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 23 Jul 2019 09:48:11 -0400 Subject: [PATCH] Fix a `ListenerExecutionFailedException` usage https://build.spring.io/browse/AMQP-AMQP21X-55/ --- .../amqp/rabbit/listener/ContainerUtilsTests.java | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/ContainerUtilsTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/ContainerUtilsTests.java index 91181183..ea580af1 100644 --- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/ContainerUtilsTests.java +++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/ContainerUtilsTests.java @@ -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(); } }