diff --git a/cluster-tests/src/test/java/io/scalecube/transport/netty/TransportTests.java b/cluster-tests/src/test/java/io/scalecube/transport/netty/TransportTests.java
index 9109f66e..d6fabb60 100644
--- a/cluster-tests/src/test/java/io/scalecube/transport/netty/TransportTests.java
+++ b/cluster-tests/src/test/java/io/scalecube/transport/netty/TransportTests.java
@@ -142,7 +142,8 @@ public void testConnect(Context context) {
 
     StepVerifier.create(
             new TransportWrapper(client)
-                .send(serverMember, Message.builder().sender(clientMember).data("Hola!").build()))
+                .send(serverMember, Message.builder().sender(clientMember).data("Hola!").build())
+                .repeat(2))
         .verifyComplete();
 
     client.stop().block(TIMEOUT);