From e59cb569a6e93d17aa7a0e49388664fa66e5a5bc Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Wed, 15 Nov 2017 13:50:40 -0500 Subject: [PATCH] Fix failing integ test on CI --- .../cloud/stream/binder/kafka/KafkaBinderTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java index e96df67de..ea9831778 100644 --- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java +++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java @@ -520,7 +520,7 @@ public class KafkaBinderTests extends moduleOutputChannel.send(message); - Message receivedMessage = receive(dlqChannel, 5); + Message receivedMessage = dlqChannel.receive(5000); //Ensure that we didn't receive anything on DLQ because of serializer config missing //on dlq producer while native Decoding is enabled. assertThat(receivedMessage).isNull();