Fix a ClassCastException in EmbeddedMessageChannel

netty · Jun 12, 2012 · 90b12ba · 90b12ba
1 parent a35aeb8
commit 90b12ba
Showing 1 changed file with 2 additions and 3 deletions.
diff --git 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 @@
 
 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<Object>(), handlers);
+        super(Unpooled.messageBuffer(), handlers);
     }
 
     @Override