diff --git a/transport/src/main/java/io/netty/channel/ChannelInboundMessageHandlerAdapter.java b/transport/src/main/java/io/netty/channel/ChannelInboundMessageHandlerAdapter.java index 6c8519e1fa..127e0048f1 100644 --- a/transport/src/main/java/io/netty/channel/ChannelInboundMessageHandlerAdapter.java +++ b/transport/src/main/java/io/netty/channel/ChannelInboundMessageHandlerAdapter.java @@ -28,7 +28,7 @@ public abstract class ChannelInboundMessageHandlerAdapter @Override public final void inboundBufferUpdated(ChannelHandlerContext ctx) throws Exception { - firstMessageReceived(ctx); + beginMessageReceived(ctx); MessageBuf in = ctx.inboundMessageBuffer(); for (;;) { @@ -43,10 +43,10 @@ public abstract class ChannelInboundMessageHandlerAdapter } } - lastMessageReceived(ctx); + endMessageReceived(ctx); } - public void firstMessageReceived(ChannelHandlerContext ctx) throws Exception { } + public void beginMessageReceived(ChannelHandlerContext ctx) throws Exception { } public abstract void messageReceived(ChannelHandlerContext ctx, I msg) throws Exception; - public void lastMessageReceived(ChannelHandlerContext ctx) throws Exception { } + public void endMessageReceived(ChannelHandlerContext ctx) throws Exception { } }