diff --git a/transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpMessageCompletionHandler.java b/transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpMessageCompletionHandler.java index 0a09a5e847..7f6de637eb 100644 --- a/transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpMessageCompletionHandler.java +++ b/transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpMessageCompletionHandler.java @@ -22,10 +22,10 @@ import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandler; import io.netty.channel.sctp.SctpMessage; import io.netty.handler.codec.MessageToMessageDecoder; +import io.netty.util.collection.IntObjectHashMap; +import io.netty.util.collection.IntObjectMap; -import java.util.HashMap; import java.util.List; -import java.util.Map; /** * {@link MessageToMessageDecoder} which will take care of handle fragmented {@link SctpMessage}s, so @@ -33,7 +33,7 @@ import java.util.Map; * {@link ChannelInboundHandler}. */ public class SctpMessageCompletionHandler extends MessageToMessageDecoder { - private final Map fragments = new HashMap(); + private final IntObjectMap fragments = new IntObjectHashMap(); @Override protected void decode(ChannelHandlerContext ctx, SctpMessage msg, List out) throws Exception {