diff --git a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java
index a70b13aea3b..92d3f6befd4 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java
@@ -222,7 +222,7 @@ public class ReactorNettyTcpClient<P> implements TcpOperations<P> {
 						.map(retrySignal -> (int) retrySignal.totalRetriesInARow())
 						.flatMap(attempt -> reconnect(attempt, strategy))))
 				.repeatWhen(flux -> flux
-						.scan(1, (count, element) -> count++)
+					.scan(1, (count, element) -> count + 1)
 						.flatMap(attempt -> reconnect(attempt, strategy)))
 				.subscribe();
 		return connectFuture;