diff --git a/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java b/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java index 32bf53e0b..ae2eae1ba 100644 --- a/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java +++ b/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java @@ -131,7 +131,7 @@ public class CommandDecoder extends ReplayingDecoder { } sendNext(ctx, data); } catch (Exception e) { - log.error("Unable to decode data. reply: {}, channel: {}, command: {}", LogHelper.toString(in), ctx.channel(), data, e); + log.error("Unable to decode data. channel: " + ctx.channel() + ", reply: " + LogHelper.toString(in) + ", command: " + LogHelper.toString(data), e); cmd.tryFailure(e); sendNext(ctx); throw e; @@ -152,7 +152,7 @@ public class CommandDecoder extends ReplayingDecoder { } sendNext(ctx); } catch (Exception e) { - log.error("Unable to decode data. channel: {} message: {}", ctx.channel(), LogHelper.toString(in), e); + log.error("Unable to decode data. channel: " + ctx.channel() + ", reply: " + LogHelper.toString(in), e); sendNext(ctx); throw e; } diff --git a/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java b/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java index 54dcd3a30..38d28d63c 100644 --- a/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java +++ b/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java @@ -79,7 +79,7 @@ public class CommandPubSubDecoder extends CommandDecoder { } sendNext(ctx); } catch (Exception e) { - log.error("Unable to decode data. channel: {} message: {}", ctx.channel(), LogHelper.toString(in), e); + log.error("Unable to decode data. channel: " + ctx.channel() + ", reply: " + LogHelper.toString(in), e); sendNext(ctx); throw e; } @@ -95,7 +95,7 @@ public class CommandPubSubDecoder extends CommandDecoder { } sendNext(ctx, data); } catch (Exception e) { - log.error("Unable to decode data. channel: {} message: {}", ctx.channel(), LogHelper.toString(in), e); + log.error("Unable to decode data. channel: " + ctx.channel() + ", reply: " + LogHelper.toString(in), e); cmd.tryFailure(e); sendNext(ctx); throw e;