diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/FailoverClientConnectionFactoryTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/FailoverClientConnectionFactoryTests.java index efc6bd57c9..78fff520f4 100644 --- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/FailoverClientConnectionFactoryTests.java +++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/FailoverClientConnectionFactoryTests.java @@ -220,6 +220,9 @@ public class FailoverClientConnectionFactoryTests { }); TcpNetClientConnectionFactory cf1 = new TcpNetClientConnectionFactory("localhost", ss1.getLocalPort()); AbstractClientConnectionFactory cf2 = mock(AbstractClientConnectionFactory.class); + List factories = new ArrayList(); + 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;