From 15de8dce3090783da352233f5500361862449667 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Mon, 25 Feb 2019 13:02:06 +0300 Subject: [PATCH] refactoring --- .../main/java/org/redisson/cache/LocalCachedMessageCodec.java | 2 +- .../main/java/org/redisson/client/handler/CommandDecoder.java | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/redisson/src/main/java/org/redisson/cache/LocalCachedMessageCodec.java b/redisson/src/main/java/org/redisson/cache/LocalCachedMessageCodec.java index 3e584971e..ba047a17e 100644 --- a/redisson/src/main/java/org/redisson/cache/LocalCachedMessageCodec.java +++ b/redisson/src/main/java/org/redisson/cache/LocalCachedMessageCodec.java @@ -78,7 +78,7 @@ public class LocalCachedMessageCodec extends BaseCodec { if (type == 0x3) { byte len = buf.readByte(); - CharSequence requestId = buf.readCharSequence(len, CharsetUtil.UTF_8); + CharSequence requestId = buf.readCharSequence(len, CharsetUtil.US_ASCII); long timeout = buf.readLong(); int hashesCount = buf.readInt(); byte[][] hashes = new byte[hashesCount][]; 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 2fc915451..2e039cc6c 100644 --- a/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java +++ b/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java @@ -80,8 +80,6 @@ public class CommandDecoder extends ReplayingDecoder { private static final char LF = '\n'; private static final char ZERO = '0'; - public enum Status {NORMAL, FILL_BUFFER, DECODE_BUFFER} - final ExecutorService executor; private final boolean decodeInExecutor;