From 633a09480b5bf71ee634301155efe94ff89f5a6a Mon Sep 17 00:00:00 2001 From: Max Fortun Date: Tue, 9 Jul 2024 13:43:49 -0400 Subject: [PATCH] updated --- src/main/java/redis/clients/jedis/Protocol.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/main/java/redis/clients/jedis/Protocol.java b/src/main/java/redis/clients/jedis/Protocol.java index 448bd7ff12..a24ce95cc2 100644 --- a/src/main/java/redis/clients/jedis/Protocol.java +++ b/src/main/java/redis/clients/jedis/Protocol.java @@ -15,7 +15,11 @@ import redis.clients.jedis.util.RedisOutputStream; import redis.clients.jedis.util.SafeEncoder; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + public final class Protocol { + protected static Logger logger = LoggerFactory.getLogger(Protocol.class.getName()); public static final String DEFAULT_HOST = "127.0.0.1"; public static final int DEFAULT_PORT = 6379; @@ -63,6 +67,15 @@ private Protocol() { } public static void sendCommand(final RedisOutputStream os, CommandArguments args) { + if(logger.isDebugEnabled()) { + StringBuilder logMessage = new StringBuilder(); + for (Rawable arg : args) { + logMessage.append(new String(arg.getRaw())); + logMessage.append(" "); + } + logger.debug(logMessage.toString()); + } + try { os.write(ASTERISK_BYTE); os.writeIntCrLf(args.size());