Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-536: Fix test for backport

Browse Source
This commit is contained in:
Gary Russell
2021-03-25 18:46:35 -04:00
parent dc51a8cbf3
commit d6a4422aa9
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/FailoverClientConnectionFactoryTests.java
View File

@@ -220,6 +220,9 @@ public class FailoverClientConnectionFactoryTests {
});
TcpNetClientConnectionFactory cf1 = new TcpNetClientConnectionFactory("localhost", ss1.getLocalPort());
AbstractClientConnectionFactory cf2 = mock(AbstractClientConnectionFactory.class);
List<AbstractClientConnectionFactory> factories = new ArrayList<AbstractClientConnectionFactory>();
factories.add(cf1);
factories.add(cf2);
doThrow(new UncheckedIOException(new IOException("fail"))).when(cf2).getConnection();
CountDownLatch latch = new CountDownLatch(2);
cf1.setApplicationEventPublisher(event -> {
@@ -228,7 +231,7 @@ public class FailoverClientConnectionFactoryTests {
}
});
cf2.setApplicationEventPublisher(event -> { });
FailoverClientConnectionFactory fccf = new FailoverClientConnectionFactory(List.of(cf1, cf2));
FailoverClientConnectionFactory fccf = new FailoverClientConnectionFactory(factories);
fccf.registerListener(msf -> {
latch.countDown();
return false;