From 8fa1ea76b49260e35d5afac13a139050a69c142e Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Thu, 10 May 2018 15:52:02 -0400 Subject: [PATCH] INT-4422: Fix TCP Pool tests --- .../tcp/connection/CachingClientConnectionFactoryTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/CachingClientConnectionFactoryTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/CachingClientConnectionFactoryTests.java index 68ff5dcc65..61967f173e 100644 --- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/CachingClientConnectionFactoryTests.java +++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/CachingClientConnectionFactoryTests.java @@ -77,9 +77,9 @@ import org.springframework.integration.ip.tcp.serializer.ByteArrayCrLfSerializer import org.springframework.integration.ip.util.TestingUtilities; import org.springframework.integration.support.MessageBuilder; import org.springframework.integration.test.util.TestUtils; +import org.springframework.integration.util.PoolItemNotAvailableException; import org.springframework.integration.util.SimplePool; import org.springframework.messaging.Message; -import org.springframework.messaging.MessagingException; import org.springframework.messaging.PollableChannel; import org.springframework.messaging.SubscribableChannel; import org.springframework.messaging.support.ErrorMessage; @@ -216,7 +216,7 @@ public class CachingClientConnectionFactoryTests { conn2a.close(); } - @Test(expected = MessagingException.class) + @Test(expected = PoolItemNotAvailableException.class) public void testLimit() throws Exception { AbstractClientConnectionFactory factory = mock(AbstractClientConnectionFactory.class); when(factory.isRunning()).thenReturn(true);