Fixed incorrect conditional statements

src/main/java/org/jboss/netty/handler/codec/embedder/AbstractCodecEmbedder.java

@@ -55,7 +55,7 @@ abstract class AbstractCodecEmbedder<T> implements CodecEmbedder<T> {
         fireChannelDisconnected(context, channel);
         fireChannelUnbound(context, channel);
         fireChannelClosed(context, channel);
-        return context.productQueue.isEmpty();
+        return !context.productQueue.isEmpty();
     }
 
     @SuppressWarnings("unchecked")

src/main/java/org/jboss/netty/handler/codec/embedder/DecoderEmbedder.java

@@ -38,7 +38,7 @@ public class DecoderEmbedder<T> extends AbstractCodecEmbedder<T> {
     }
 
     public boolean offer(Object input) {
-        fireMessageReceived(context.getChannel(), input);
-        return context.productQueue.isEmpty();
+        fireMessageReceived(context, context.getChannel(), input);
+        return !context.productQueue.isEmpty();
     }
 }

src/main/java/org/jboss/netty/handler/codec/embedder/EncoderEmbedder.java

@@ -41,6 +41,6 @@ public class EncoderEmbedder<T> extends AbstractCodecEmbedder<T> {
     public boolean offer(Object input) {
         Channel channel = context.getChannel();
         write(context, channel, succeededFuture(channel), input);
-        return context.productQueue.isEmpty();
+        return !context.productQueue.isEmpty();
     }
 }