diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionEventTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionEventTests.java
index 3b0e88554b..74b738da30 100644
--- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionEventTests.java
+++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionEventTests.java
@@ -316,7 +316,20 @@ public class ConnectionEventTests {
 
 	@Test
 	public void testFailConnect() {
-		TcpNetClientConnectionFactory ccf = new TcpNetClientConnectionFactory("junkjunk", 1234);
+		AbstractClientConnectionFactory ccf = new AbstractClientConnectionFactory("junkjunk", 1234) {
+
+			@Override
+			protected boolean isActive() {
+				return true;
+			}
+
+			@Override
+			protected TcpConnectionSupport buildNewConnection() throws Exception {
+				throw new UnknownHostException("Mocking for test ");
+			}
+
+		};
+
 		final AtomicReference<ApplicationEvent> failEvent = new AtomicReference<ApplicationEvent>();
 		ccf.setApplicationEventPublisher(new ApplicationEventPublisher() {