Merge 5c161775df into a92e4562f1

redisson/src/main/java/org/redisson/command/RedisExecutor.java

@@ -233,7 +233,7 @@ public class RedisExecutor<V, R> {
                         "Increase connection pool size or timeout. "
                         + "Node source: " + source
                         + ", " + LogHelper.toString(command, params)
-                        + " after " + attempt + "of " + attempts + " retry attempts");
+                        + " after " + attempt + " of " + attempts + " retry attempts");
 
                 attemptPromise.completeExceptionally(exception);
             }
@@ -258,7 +258,7 @@ public class RedisExecutor<V, R> {
                         + " Netty pending tasks: " + pendingTasks + ","
                         + " Node source: " + source + ", connection: " + connectionFuture.join()
                         + ", " + LogHelper.toString(command, params)
-                        + " after " + attempt + "of " + attempts + " retry attempts");
+                        + " after " + attempt + " of " + attempts + " retry attempts");
                 attemptPromise.completeExceptionally(exception);
             }
         };
@@ -284,7 +284,7 @@ public class RedisExecutor<V, R> {
                                 "Increase connection pool size. "
                                 + "Node source: " + source
                                 + ", " + LogHelper.toString(command, params)
-                                + " after " + attempt + "of " + attempts + " retry attempts");
+                                + " after " + attempt + " of " + attempts + " retry attempts");
                 } else {
                     if (connectionFuture.isDone() && !connectionFuture.isCompletedExceptionally()) {
                         if (writeFuture == null || !writeFuture.isDone()) {
@@ -298,7 +298,7 @@ public class RedisExecutor<V, R> {
                                                 " Netty pending tasks: " + pendingTasks + ","
                                               + " Node source: " + source + ", connection: " + getNow(connectionFuture)
                                                 + ", " + LogHelper.toString(command, params)
-                                                + " after " + attempt + "of " + attempts + " retry attempts");
+                                                + " after " + attempt + " of " + attempts + " retry attempts");
                                     }
                                     attemptPromise.completeExceptionally(exception);
                                 }
@@ -376,7 +376,7 @@ public class RedisExecutor<V, R> {
                             "Node source: "
                     + source + ", connection: " + connection +
                     ", " + LogHelper.toString(command, params)
-                    + " after " + attempt + "of " + attempts + " retry attempts",
+                    + " after " + attempt + " of " + attempts + " retry attempts",
                     future.cause());
             tryComplete(attemptPromise, exception);
             return;
@@ -465,7 +465,7 @@ public class RedisExecutor<V, R> {
             int pendingTasks = countPendingTasks();
             attemptPromise.completeExceptionally(
                     new RedisResponseTimeoutException("Redis server response timeout (" + timeoutAmount + " ms) occured"
-                            + " after " + attempt + "of " + attempts + " retry attempts,"
+                            + " after " + attempt + " of " + attempts + " retry attempts,"
                             + " is non-idempotent command: " + (command != null && command.isNoRetry())
                             + " Check connection with Redis node: " + connection.getRedisClient().getAddr() + " for TCP packet drops or bandwidth limits. "
                             + " Try to increase nettyThreads and/or timeout settings."