From b73507df0315474eb5a931193bdac12aa4d9646c Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Sun, 4 Feb 2018 13:29:40 -0500 Subject: [PATCH] fixed RabbitBinderTest to accomodate DefaultPollableMessageSource's signature change --- .../cloud/stream/binder/rabbit/RabbitBinderTests.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java index de189f658..6c2c4ab56 100644 --- a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java +++ b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java @@ -1330,7 +1330,7 @@ public class RabbitBinderTests extends @Test public void testPolledConsumer() throws Exception { RabbitTestBinder binder = getBinder(); - PollableSource inboundBindTarget = new DefaultPollableMessageSource(); + PollableSource inboundBindTarget = new DefaultPollableMessageSource(this.messageConverter); Binding> binding = binder.bindPollableConsumer("pollable", "group", inboundBindTarget, createConsumerProperties()); RabbitTemplate template = new RabbitTemplate(this.rabbitAvailableRule.getResource()); @@ -1351,7 +1351,7 @@ public class RabbitBinderTests extends @Test public void testPolledConsumerWithDlq() throws Exception { RabbitTestBinder binder = getBinder(); - PollableSource inboundBindTarget = new DefaultPollableMessageSource(); + PollableSource inboundBindTarget = new DefaultPollableMessageSource(this.messageConverter); ExtendedConsumerProperties properties = createConsumerProperties(); properties.setMaxAttempts(2); properties.setBackOffInitialInterval(0); @@ -1380,7 +1380,7 @@ public class RabbitBinderTests extends @Test public void testPolledConsumerWithDlqNoRetry() throws Exception { RabbitTestBinder binder = getBinder(); - PollableSource inboundBindTarget = new DefaultPollableMessageSource(); + PollableSource inboundBindTarget = new DefaultPollableMessageSource(this.messageConverter); ExtendedConsumerProperties properties = createConsumerProperties(); properties.setMaxAttempts(1); // properties.getExtension().setRequeueRejected(true); // loops, correctly @@ -1409,7 +1409,7 @@ public class RabbitBinderTests extends @Test public void testPolledConsumerWithDlqRePub() throws Exception { RabbitTestBinder binder = getBinder(); - PollableSource inboundBindTarget = new DefaultPollableMessageSource(); + PollableSource inboundBindTarget = new DefaultPollableMessageSource(this.messageConverter); ExtendedConsumerProperties properties = createConsumerProperties(); properties.setMaxAttempts(2); properties.setBackOffInitialInterval(0);