diff --git a/transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpInboundByteStreamHandler.java b/transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpInboundByteStreamHandler.java index a770988f92..f6a3ad1daa 100644 --- a/transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpInboundByteStreamHandler.java +++ b/transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpInboundByteStreamHandler.java @@ -40,14 +40,14 @@ public class SctpInboundByteStreamHandler extends ChannelInboundMessageHandlerAd } @Override - public boolean acceptInboundMessage(Object msg) throws Exception { + public final boolean acceptInboundMessage(Object msg) throws Exception { if (super.acceptInboundMessage(msg)) { - return isDecodable((SctpMessage) msg); + return acceptInboundMessage((SctpMessage) msg); } return false; } - protected boolean isDecodable(SctpMessage msg) { + protected boolean acceptInboundMessage(SctpMessage msg) { return msg.protocolIdentifier() == protocolIdentifier && msg.streamIdentifier() == streamIdentifier; }