diff --git a/codec/src/main/java/io/netty/handler/codec/redis/RedisDecoder.java b/codec/src/main/java/io/netty/handler/codec/redis/RedisDecoder.java index cfeb718455..03152726f9 100644 --- a/codec/src/main/java/io/netty/handler/codec/redis/RedisDecoder.java +++ b/codec/src/main/java/io/netty/handler/codec/redis/RedisDecoder.java @@ -96,7 +96,7 @@ public class RedisDecoder extends ReplayingDecoder { } @Override - public Reply decode(ChannelInboundHandlerContext channelHandlerContext, ChannelBuffer channelBuffer, VoidEnum anEnum) throws Exception { + public Reply decode(ChannelInboundHandlerContext channelHandlerContext, ChannelBuffer channelBuffer) throws Exception { if (reply != null) { reply.read(this, channelBuffer); Reply ret = reply; diff --git a/codec/src/test/java/io/netty/handler/codec/ReplayingDecoderTest.java b/codec/src/test/java/io/netty/handler/codec/ReplayingDecoderTest.java index 5437ceab51..4cb16bb27f 100644 --- a/codec/src/test/java/io/netty/handler/codec/ReplayingDecoderTest.java +++ b/codec/src/test/java/io/netty/handler/codec/ReplayingDecoderTest.java @@ -54,8 +54,7 @@ public class ReplayingDecoderTest { } @Override - public ChannelBuffer decode(ChannelInboundHandlerContext ctx, - ChannelBuffer in, VoidEnum state) throws Exception { + public ChannelBuffer decode(ChannelInboundHandlerContext ctx, ChannelBuffer in) { ChannelBuffer msg = in.readBytes(in.bytesBefore(ChannelBufferIndexFinder.LF)); in.skipBytes(1); return msg;