diff --git a/src/main/java/org/jboss/netty/handler/codec/embedder/AbstractCodecEmbedder.java b/src/main/java/org/jboss/netty/handler/codec/embedder/AbstractCodecEmbedder.java
index f4786e8855..7c5daef5dd 100644
--- a/src/main/java/org/jboss/netty/handler/codec/embedder/AbstractCodecEmbedder.java
+++ b/src/main/java/org/jboss/netty/handler/codec/embedder/AbstractCodecEmbedder.java
@@ -135,7 +135,8 @@ public abstract class AbstractCodecEmbedder<T> implements CodecEmbedder<T> {
 
         private void handleEvent(ChannelEvent e) {
             if (e instanceof MessageEvent) {
-                productQueue.offer(((MessageEvent) e).getMessage());
+                boolean offered = productQueue.offer(((MessageEvent) e).getMessage());
+                assert offered;
             } else if (e instanceof ExceptionEvent) {
                 throw new CodecEmbedderException(((ExceptionEvent) e).getCause());
             }