From 9ff61997953047e3a9222edb497901b1ff35c720 Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Thu, 14 Mar 2024 14:15:39 +0300
Subject: [PATCH] debug messages added in reattachBlockingQueue method. #5670

---
 .../java/org/redisson/connection/ClientConnectionsEntry.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java b/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java
index 056df2048..e76f857de 100644
--- a/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java
+++ b/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java
@@ -177,6 +177,7 @@ public class ClientConnectionsEntry {
 
         MasterSlaveEntry entry = connectionManager.getEntry(key);
         if (entry == null) {
+            log.debug("Unable to get entry for {} during blocking command reattach {}", key, commandData);
             connectionManager.getServiceManager().newTimeout(timeout ->
                     reattachBlockingQueue(commandData), 1, TimeUnit.SECONDS);
             return;
@@ -185,6 +186,7 @@ public class ClientConnectionsEntry {
         CompletableFuture<RedisConnection> newConnectionFuture = entry.connectionWriteOp(commandData.getCommand());
         newConnectionFuture.whenComplete((newConnection, e) -> {
             if (e != null) {
+                log.debug("Unable to acquire connection during blocking command reattach {}", commandData, e);
                 connectionManager.getServiceManager().newTimeout(timeout ->
                         reattachBlockingQueue(commandData), 1, TimeUnit.SECONDS);
                 return;
@@ -197,6 +199,7 @@ public class ClientConnectionsEntry {
             ChannelFuture channelFuture = newConnection.send(commandData);
             channelFuture.addListener(future -> {
                 if (!future.isSuccess()) {
+                    log.debug("Unable to send a command during blocking command reattach {}", commandData, future.cause());
                     connectionManager.getServiceManager().newTimeout(timeout ->
                             reattachBlockingQueue(commandData), 1, TimeUnit.SECONDS);
                     return;