diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionFactoryTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionFactoryTests.java
index 0f4af5d1f5..98d6845fec 100644
--- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionFactoryTests.java
+++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionFactoryTests.java
@@ -136,7 +136,7 @@ public class ConnectionFactoryTests {
 
 		FooEvent event = new FooEvent(client, "foo");
 		client.publishEvent(event);
-		assertEquals(expected + 1, events.size());
+		assertThat(events.size(), greaterThanOrEqualTo(expected + 1));
 
 		try {
 			event = new FooEvent(mock(TcpConnectionSupport.class), "foo");