Merge "Bug 1072 -Add OF13 pre-req for PCP match in TestCommandProvider"

[openflowplugin.git] / drop-test / src / main / java / org / opendaylight / openflowplugin / droptest / DropTestRpcProvider.java

diff --git a/drop-test/src/main/java/org/opendaylight/openflowplugin/droptest/DropTestRpcProvider.java b/drop-test/src/main/java/org/opendaylight/openflowplugin/droptest/DropTestRpcProvider.java
index 4c920122135c83f70401a2ee611d1648302f11da..587505a8a8ad0da428f0638915f6ec5befbac897 100644 (file)
--- a/drop-test/src/main/java/org/opendaylight/openflowplugin/droptest/DropTestRpcProvider.java
+++ b/drop-test/src/main/java/org/opendaylight/openflowplugin/droptest/DropTestRpcProvider.java
@@ -40,25 +40,26 @@ public class DropTestRpcProvider implements AutoCloseable {
     }
 
     public void start() {
-        this.commiter = new DropTestRpcSender(this, this.getFlowService());;
+        this.commiter = new DropTestRpcSender(this.getFlowService());
         this.listenerRegistration = this.getNotificationService().registerNotificationListener(this.commiter);
         LOG.debug("DropTestProvider Started.");
     }
-    
+
     public DropTestStats getStats() {
-       if(this.commiter != null) {
-               return this.commiter.getStats();
-       } else {
-               return new DropTestStats("Not initialized yet.");               
-       }
+        if(this.commiter != null) {
+            return this.commiter.getStats();
+        } else {
+            return new DropTestStats("Not initialized yet.");
+        }
     }
-    
+
     public void clearStats() {
-       if(this.commiter != null) {
-               this.commiter.clearStats();
-       }
+        if(this.commiter != null) {
+            this.commiter.clearStats();
+        }
     }
 
+    @Override
     public void close() {
         try {
             LOG.debug("DropTestProvider stopped.");