diff --git a/transport/src/main/java/io/netty/channel/embedded/EmbeddedChannel.java b/transport/src/main/java/io/netty/channel/embedded/EmbeddedChannel.java index d776b18119..976d0b0fbb 100644 --- a/transport/src/main/java/io/netty/channel/embedded/EmbeddedChannel.java +++ b/transport/src/main/java/io/netty/channel/embedded/EmbeddedChannel.java @@ -26,6 +26,7 @@ import io.netty.channel.ChannelConfig; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelFutureListener; import io.netty.channel.ChannelHandler; +import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelId; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelMetadata; @@ -873,8 +874,8 @@ public class EmbeddedChannel extends AbstractChannel { } @Override - protected void onUnhandledInboundMessage(Object msg) { - handleInboundMessage(msg); + protected void onUnhandledInboundMessage(ChannelHandlerContext ctx, Object msg) { + handleInboundMessage(msg); } } }