From 55458034b37ff1c1491deb2649744859d4f0fd2b Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 25 Jun 2018 23:24:09 -0400 Subject: [PATCH] GH-1234 Fixed broken test Resolves #1234 --- .../cloud/stream/binding/BindingServiceTests.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java index 15488dbe3..4fbab6801 100644 --- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java +++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java @@ -27,7 +27,6 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicReference; -import org.junit.Ignore; import org.junit.Test; import org.mockito.ArgumentCaptor; import org.mockito.Mockito; @@ -396,7 +395,6 @@ public class BindingServiceTests { @SuppressWarnings({ "rawtypes", "unchecked" }) @Test - @Ignore // Inconsistent, needs fixing public void testLateBindingConsumer() throws Exception { BindingServiceProperties properties = new BindingServiceProperties(); properties.setBindingRetryInterval(1); @@ -428,7 +426,7 @@ public class BindingServiceTests { Binding.class); int n = 0; while (n++ < 300 && delegate == null) { - Thread.sleep(100); + Thread.sleep(200); } assertThat(delegate).isSameAs(mockBinding); service.unbindConsumers(inputChannelName);