Fix failing integ test on CI

2017-11-15 13:50:40 -05:00
parent b0c4f0cfcd
commit e59cb569a6
1 changed files with 1 additions and 1 deletions
--- 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();