PCEP sucessfull connection now implemented. Fixed minor bug in parsing.

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

diff --git a/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionOutboundHandler.java b/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionOutboundHandler.java
index c919f2f3a265961947c42072d258dacd4c09ead5..2671ec7fdac16ac01792e22ecf2cb98761344184 100644 (file)
--- a/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionOutboundHandler.java
+++ b/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionOutboundHandler.java
@@ -9,26 +9,9 @@ package org.opendaylight.protocol.framework;
 
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelOutboundHandlerAdapter;
-import io.netty.channel.MessageList;
 
 public final class ProtocolSessionOutboundHandler extends ChannelOutboundHandlerAdapter {
 
-       private final ProtocolSession session;
-
-       public ProtocolSessionOutboundHandler(final ProtocolSession session) {
-               this.session = session;
-       }
-
-       @Override
-       public void handlerAdded(final ChannelHandlerContext ctx) throws Exception {
-               this.session.startSession();
-       }
-
-       @Override
-       public void handlerRemoved(final ChannelHandlerContext ctx) throws Exception {
-               this.session.close();
-       }
-
        @Override
        public void exceptionCaught(final ChannelHandlerContext ctx, final Throwable cause) {
                // TODO:
@@ -37,6 +20,6 @@ public final class ProtocolSessionOutboundHandler extends ChannelOutboundHandler
        }
 
        public void writeDown(final ChannelHandlerContext ctx, final ProtocolMessage msg) throws Exception {
-               this.write(ctx, MessageList.<Object> newInstance(msg), ctx.newPromise());
+               this.write(ctx, msg, ctx.newPromise());
        }
 }