BUG-54 : switched channel pipeline to be protocol specific.

[bgpcep.git] / framework / src / main / java / org / opendaylight / protocol / framework / ProtocolMessageEncoder.java

diff --git a/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolMessageEncoder.java b/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolMessageEncoder.java
index c54c780185c1bcf62e058cb59ccd4bf3b44dd031..ce19c0d930cec3d735e4efcbb5630d6e0925869c 100644 (file)
--- a/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolMessageEncoder.java
+++ b/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolMessageEncoder.java
@@ -16,7 +16,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @Sharable
-final class ProtocolMessageEncoder<T extends ProtocolMessage> extends MessageToByteEncoder<Object> {
+public final class ProtocolMessageEncoder<T extends ProtocolMessage> extends MessageToByteEncoder<Object> {
 
        private final static Logger logger = LoggerFactory.getLogger(ProtocolMessageEncoder.class);
 
@@ -29,6 +29,7 @@ final class ProtocolMessageEncoder<T extends ProtocolMessage> extends MessageToB
        @Override
        protected void encode(final ChannelHandlerContext ctx, final Object msg, final ByteBuf out) throws Exception {
                logger.debug("Sent to encode : {}", msg);
-               out.writeBytes(this.factory.put((T)msg));
+               final byte[] bytes = this.factory.put((T) msg);
+               out.writeBytes(bytes);
        }
 }