BUG-1997: moving barrier after message

[openflowplugin.git] / openflowplugin / src / main / java / org / opendaylight / openflowplugin / openflow / md / core / sal / OFRpcTask.java

diff --git a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/OFRpcTask.java b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/OFRpcTask.java
index 79764f9dd09df8ec5e29b2c7707e0edfab7d4cc3..4ef57265e315dccb20edcb8565ed559f2599991b 100644 (file)
--- a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/OFRpcTask.java
+++ b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/OFRpcTask.java
@@ -11,7 +11,7 @@ import java.util.concurrent.Callable;
 import java.util.concurrent.TimeUnit;
 
 import org.opendaylight.controller.sal.binding.api.NotificationProviderService;
-import org.opendaylight.openflowplugin.openflow.md.core.SwitchConnectionDistinguisher;
+import org.opendaylight.openflowplugin.api.openflow.md.core.SwitchConnectionDistinguisher;
 import org.opendaylight.openflowplugin.openflow.md.core.session.IMessageDispatchService;
 import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;
 
@@ -30,7 +30,7 @@ public abstract class OFRpcTask<T, K> implements Callable<ListenableFuture<K>> {
     
     /**
      * @param taskContext
-     * @param input 
+     * @param input
      * @param cookie 
      */
     public OFRpcTask(OFRpcTaskContext taskContext, SwitchConnectionDistinguisher cookie, T input) {
@@ -129,4 +129,11 @@ public abstract class OFRpcTask<T, K> implements Callable<ListenableFuture<K>> {
         ListenableFuture<ListenableFuture<K>> compoundResult = getTaskContext().getRpcPool().submit(this);
         return Futures.dereference(compoundResult);
     }
+    
+    /**
+     * @return required barrier value
+     */
+    public Boolean isBarrier() {
+        return null;
+    }
 }