From 8d5f794461f007d0ff58178b210b49d42a4f4681 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 26 Aug 2019 13:55:52 -0400 Subject: [PATCH] Remove the sleep added in the previous commit --- .../cloud/stream/binder/kafka/KafkaBinderTests.java | 2 -- 1 file changed, 2 deletions(-) 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 e6134b557..d7d3d5b56 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 @@ -544,8 +544,6 @@ public class KafkaBinderTests extends Message receivedMessage = receive(dlqChannel, 5); assertThat(receivedMessage).isNotNull(); assertThat(receivedMessage.getPayload()).isEqualTo("foo".getBytes()); - //Adding a 1 second sleep to give the retrying enough time to complete. - Thread.sleep(1000); assertThat(handler.getInvocationCount()) .isEqualTo(consumerProperties.getMaxAttempts()); assertThat(receivedMessage.getHeaders()