From d6a4422aa912b2f91d699f0a760f3bf6fa4c4565 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Thu, 25 Mar 2021 18:46:35 -0400 Subject: [PATCH] GH-536: Fix test for backport --- .../tcp/connection/FailoverClientConnectionFactoryTests.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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;