@ -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][];
@ -80,8 +80,6 @@ public class CommandDecoder extends ReplayingDecoder<State> {
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;