diff --git a/src/main/java/org/redisson/client/handler/RedisEncoder.java b/src/main/java/org/redisson/client/handler/RedisEncoder.java index 735ea6eb3..8bea0feeb 100644 --- a/src/main/java/org/redisson/client/handler/RedisEncoder.java +++ b/src/main/java/org/redisson/client/handler/RedisEncoder.java @@ -20,6 +20,7 @@ import java.util.Arrays; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerContext; import io.netty.handler.codec.MessageToByteEncoder; +import io.netty.util.CharsetUtil; public class RedisEncoder extends MessageToByteEncoder> { @@ -51,8 +52,8 @@ public class RedisEncoder extends MessageToByteEncoder i++; } -// String o = out.toString(CharsetUtil.UTF_8); -// System.out.println(o); + String o = out.toString(CharsetUtil.UTF_8); + System.out.println(o); } private void writeArgument(ByteBuf out, byte[] arg) { diff --git a/src/main/java/org/redisson/client/protocol/RedisCommands.java b/src/main/java/org/redisson/client/protocol/RedisCommands.java index fb625bbf6..d577be876 100644 --- a/src/main/java/org/redisson/client/protocol/RedisCommands.java +++ b/src/main/java/org/redisson/client/protocol/RedisCommands.java @@ -29,6 +29,13 @@ import org.redisson.client.protocol.pubsub.PubSubStatusMessage; public interface RedisCommands { + RedisStrictCommand EVAL_BOOLEAN = new RedisStrictCommand("EVAL", new BooleanReplayConvertor()); + RedisStrictCommand EVAL_INTEGER = new RedisStrictCommand("EVAL"); + + RedisStrictCommand INCR = new RedisStrictCommand("INCR"); + RedisStrictCommand INCRBY = new RedisStrictCommand("INCRBY"); + RedisStrictCommand DECR = new RedisStrictCommand("DECR"); + RedisStrictCommand AUTH = new RedisStrictCommand("AUTH", new StringReplayDecoder()); RedisStrictCommand SELECT = new RedisStrictCommand("SELECT", new StringReplayDecoder()); RedisStrictCommand CLIENT_SETNAME = new RedisStrictCommand("CLIENT", "SETNAME", new StringReplayDecoder()); diff --git a/src/main/java/org/redisson/client/protocol/StringCodec.java b/src/main/java/org/redisson/client/protocol/StringCodec.java index ab108bcbf..bcb746fd2 100644 --- a/src/main/java/org/redisson/client/protocol/StringCodec.java +++ b/src/main/java/org/redisson/client/protocol/StringCodec.java @@ -22,6 +22,8 @@ import io.netty.util.CharsetUtil; public class StringCodec implements Codec { + public static final StringCodec INSTANCE = new StringCodec(); + @Override public byte[] encode(int paramIndex, Object in) { try {