X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflow-protocol-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowjava%2Fprotocol%2Fimpl%2Fcore%2FDelegatingInboundHandler.java;h=e0daecb2620c1acda34bcbfdda033dfac95d54f5;hb=5b05fc8e7dd2b61a076dfd1864a205b0995c7722;hp=cef6b03b94e61787b4efc8d9982c2d3d06a20082;hpb=1fe648172a622601f42a3b1c5e53e17f4d41d14b;p=openflowjava.git

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/DelegatingInboundHandler.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/DelegatingInboundHandler.java
index cef6b03b..e0daecb2 100644
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/DelegatingInboundHandler.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/DelegatingInboundHandler.java
@@ -4,6 +4,7 @@ package org.opendaylight.openflowjava.protocol.impl.core;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 
+import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionAdapterImpl;
 import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.system.rev130927.DisconnectEventBuilder;
 import org.opendaylight.yangtools.yang.binding.DataObject;
@@ -11,14 +12,15 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
+ * Holds reference to {@link ConnectionAdapterImpl} and passes messages for further processing.
+ * Also informs on switch disconnection.
  * @author michal.polkorab
- *
  */
 public class DelegatingInboundHandler extends ChannelInboundHandlerAdapter {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(DelegatingInboundHandler.class);
     
-    private MessageConsumer consumer;
+    protected MessageConsumer consumer;
     private boolean inactiveMessageSent = false;
     
     /** 
@@ -26,12 +28,14 @@ public class DelegatingInboundHandler extends ChannelInboundHandlerAdapter {
      * @param connectionAdapter reference for adapter communicating with upper layers outside library
      */
     public DelegatingInboundHandler(MessageConsumer connectionAdapter) {
-        LOGGER.info("Creating DelegatingInboundHandler");
+        LOGGER.debug("Creating DelegatingInboundHandler");
         consumer = connectionAdapter;
     }
     
     @Override
-    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+    public void channelRead(ChannelHandlerContext ctx, final Object msg)
+            throws Exception {
+        LOGGER.debug("Reading");
         consumer.consume((DataObject) msg);
     }