Fix compilation errors
This commit is contained in:
parent
ddb839eaf9
commit
9d3eeb9719
@ -96,7 +96,7 @@ public class RedisDecoder extends ReplayingDecoder<Reply, VoidEnum> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Reply decode(ChannelInboundHandlerContext<Byte> channelHandlerContext, ChannelBuffer channelBuffer, VoidEnum anEnum) throws Exception {
|
public Reply decode(ChannelInboundHandlerContext<Byte> channelHandlerContext, ChannelBuffer channelBuffer) throws Exception {
|
||||||
if (reply != null) {
|
if (reply != null) {
|
||||||
reply.read(this, channelBuffer);
|
reply.read(this, channelBuffer);
|
||||||
Reply ret = reply;
|
Reply ret = reply;
|
||||||
|
@ -54,8 +54,7 @@ public class ReplayingDecoderTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public ChannelBuffer decode(ChannelInboundHandlerContext<Byte> ctx,
|
public ChannelBuffer decode(ChannelInboundHandlerContext<Byte> ctx, ChannelBuffer in) {
|
||||||
ChannelBuffer in, VoidEnum state) throws Exception {
|
|
||||||
ChannelBuffer msg = in.readBytes(in.bytesBefore(ChannelBufferIndexFinder.LF));
|
ChannelBuffer msg = in.readBytes(in.bytesBefore(ChannelBufferIndexFinder.LF));
|
||||||
in.skipBytes(1);
|
in.skipBytes(1);
|
||||||
return msg;
|
return msg;
|
||||||
|
Loading…
Reference in New Issue
Block a user