Merge "Sending each flow/group in separate bundle add rpc instead of adding all messa...

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

diff --git a/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/MessageListenerWrapper.java b/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/MessageListenerWrapper.java
index 4b98fd8cfece67a7853356f8acc1a72dbfd357bf..daead2b130954e67d593822c14e8340ac28fa81a 100644 (file)
--- a/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/MessageListenerWrapper.java
+++ b/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/MessageListenerWrapper.java
@@ -10,7 +10,6 @@ package org.opendaylight.openflowjava.protocol.impl.core.connection;
 
 import io.netty.util.concurrent.Future;
 import io.netty.util.concurrent.GenericFutureListener;
-
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
 
 /**
@@ -21,10 +20,12 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731
  */
 public class MessageListenerWrapper {
 
-    private OfHeader msg;
-    private GenericFutureListener<Future<Void>> listener;
+    private final OfHeader msg;
+    private final GenericFutureListener<Future<Void>> listener;
 
     /**
+     * Constructor.
+     *
      * @param msg outgoing message
      * @param listener listener attached to channel.write(msg) Future
      */
@@ -34,6 +35,8 @@ public class MessageListenerWrapper {
     }
 
     /**
+     * Returns the outgoing message.
+     *
      * @return outgoing message (downstream)
      */
     public OfHeader getMsg() {
@@ -42,9 +45,11 @@ public class MessageListenerWrapper {
 
 
     /**
+     * Returns the listener listening on message sending success / failure.
+     *
      * @return listener listening on message sending success / failure
      */
     public GenericFutureListener<Future<Void>> getListener() {
         return listener;
     }
-}
\ No newline at end of file
+}