Migrate topology-manager to OSGi DS

[openflowplugin.git] / applications / topology-manager / src / main / java / org / opendaylight / openflowplugin / applications / topology / manager / OperationProcessor.java

diff --git a/applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/OperationProcessor.java b/applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/OperationProcessor.java
index 6890544f36c9a3105726bfb8f71de208019e566c..4d440c82cf5f8b966d8115bc5a769fa83db0ecbd 100644 (file)
--- a/applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/OperationProcessor.java
+++ b/applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/OperationProcessor.java
@@ -9,16 +9,20 @@ package org.opendaylight.openflowplugin.applications.topology.manager;
 
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
-import javax.annotation.PostConstruct;
 import javax.annotation.PreDestroy;
 import javax.inject.Inject;
 import javax.inject.Singleton;
 import org.opendaylight.mdsal.binding.api.DataBroker;
 import org.opendaylight.openflowplugin.common.txchain.TransactionChainManager;
+import org.osgi.service.component.annotations.Activate;
+import org.osgi.service.component.annotations.Component;
+import org.osgi.service.component.annotations.Deactivate;
+import org.osgi.service.component.annotations.Reference;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @Singleton
+@Component(service = OperationProcessor.class)
 public final class OperationProcessor implements AutoCloseable, Runnable {
     private static final Logger LOG = LoggerFactory.getLogger(OperationProcessor.class);
     private static final int MAX_TRANSACTION_OPERATIONS = 100;
@@ -31,7 +35,8 @@ public final class OperationProcessor implements AutoCloseable, Runnable {
     private volatile boolean finishing = false;
 
     @Inject
-    public OperationProcessor(final DataBroker dataBroker) {
+    @Activate
+    public OperationProcessor(@Reference final DataBroker dataBroker) {
         transactionChainManager = new TransactionChainManager(dataBroker, TOPOLOGY_MANAGER);
         transactionChainManager.activateTransactionManager();
         transactionChainManager.initialSubmitWriteTransaction();
@@ -39,6 +44,8 @@ public final class OperationProcessor implements AutoCloseable, Runnable {
         thread = new Thread(this);
         thread.setDaemon(true);
         thread.setName("ofp-topo-expo-" + FlowCapableTopologyProvider.TOPOLOGY_ID);
+        thread.start();
+        LOG.debug("OperationProcessor started");
     }
 
     void enqueueOperation(final TopologyOperation task) {
@@ -49,11 +56,6 @@ public final class OperationProcessor implements AutoCloseable, Runnable {
         }
     }
 
-    @PostConstruct
-    public void start() {
-        thread.start();
-    }
-
     @Override
     public void run() {
         while (!finishing) {
@@ -96,8 +98,9 @@ public final class OperationProcessor implements AutoCloseable, Runnable {
         }
     }
 
-    @Override
     @PreDestroy
+    @Deactivate
+    @Override
     public void close() {
         thread.interrupt();
         try {
@@ -107,7 +110,6 @@ public final class OperationProcessor implements AutoCloseable, Runnable {
         }
 
         transactionChainManager.close();
-
-        LOG.debug("OperationProcessor closed");
+        LOG.debug("OperationProcessor stopped");
     }
 }