Remove the sleep added in the previous commit

This commit is contained in:
Soby Chacko
2019-08-26 13:55:52 -04:00
parent 00c13c0035
commit 8d5f794461

View File

@@ -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()