Merge "Fixing OF Multipart messages 1) So we have a MultipartRequestDesc message...

[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / core / DelegatingInboundHandler.java

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