SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-1234 Fixed broken test

Browse Source 
Resolves #1234
This commit is contained in:
Oleg Zhurakousky
2018-06-25 23:24:09 -04:00
parent e3393b98ca
commit 819542d9e0
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/BindingServiceTests.java
View File

@@ -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;
@@ -444,7 +443,6 @@ public class BindingServiceTests {
@SuppressWarnings({ "rawtypes", "unchecked" })
@Test
@Ignore // Inconsistent, needs fixing
public void testLateBindingConsumer() throws Exception {
BindingServiceProperties properties = new BindingServiceProperties();
properties.setBindingRetryInterval(1);
@@ -476,7 +474,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);