refactoring

2.x.x
Nikita Koksharov 6 years ago
parent ac0e1f7d54
commit 76bd80eb08

@ -131,7 +131,7 @@ public class CommandDecoder extends ReplayingDecoder<State> {
}
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<State> {
}
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;
}

@ -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;

Loading…
Cancel
Save