diff --git a/transport/src/main/java/io/netty/channel/embedded/EmbeddedMessageChannel.java b/transport/src/main/java/io/netty/channel/embedded/EmbeddedMessageChannel.java index c7d08300ea..9662fb1eb0 100644 --- a/transport/src/main/java/io/netty/channel/embedded/EmbeddedMessageChannel.java +++ b/transport/src/main/java/io/netty/channel/embedded/EmbeddedMessageChannel.java @@ -17,14 +17,13 @@ package io.netty.channel.embedded; import io.netty.buffer.ChannelBufType; import io.netty.buffer.MessageBuf; +import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandler; -import java.util.ArrayDeque; - public class EmbeddedMessageChannel extends AbstractEmbeddedChannel { public EmbeddedMessageChannel(ChannelHandler... handlers) { - super(new ArrayDeque(), handlers); + super(Unpooled.messageBuffer(), handlers); } @Override