diff --git a/src/main/java/org/jboss/netty/handler/codec/replay/ReplayingDecoder.java b/src/main/java/org/jboss/netty/handler/codec/replay/ReplayingDecoder.java index 4b5ecb6773..a7cd2df038 100644 --- a/src/main/java/org/jboss/netty/handler/codec/replay/ReplayingDecoder.java +++ b/src/main/java/org/jboss/netty/handler/codec/replay/ReplayingDecoder.java @@ -503,11 +503,11 @@ public abstract class ReplayingDecoder> } // A successful decode - unfoldAndfireMessageReceived(context, result, remoteAddress); + unfoldAndFireMessageReceived(context, result, remoteAddress); } } - private void unfoldAndfireMessageReceived( + private void unfoldAndFireMessageReceived( ChannelHandlerContext context, Object result, SocketAddress remoteAddress) { if (unfold) { if (result instanceof Object[]) { @@ -546,7 +546,7 @@ public abstract class ReplayingDecoder> // notify a user that the connection was closed explicitly. Object partiallyDecoded = decodeLast(ctx, e.getChannel(), replayable, state); if (partiallyDecoded != null) { - unfoldAndfireMessageReceived(ctx, partiallyDecoded, null); + unfoldAndFireMessageReceived(ctx, partiallyDecoded, null); } } catch (ReplayError replay) { // Ignore