Bulk merge of l2gw changes

[netvirt.git] / elanmanager / impl / src / main / java / org / opendaylight / netvirt / elan / l2gw / ha / listeners / HAJobScheduler.java

diff --git a/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/ha/listeners/HAJobScheduler.java b/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/ha/listeners/HAJobScheduler.java
index 66cd2ad54711a9587f21dee82bf11d1f4e4e6a6f..16e34106d335702104152d1210af10aae6f0b5d8 100644 (file)
--- a/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/ha/listeners/HAJobScheduler.java
+++ b/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/ha/listeners/HAJobScheduler.java
@@ -26,12 +26,17 @@ public final class HAJobScheduler implements Thread.UncaughtExceptionHandler {
         ThreadFactory threadFact = new ThreadFactoryBuilder()
                 .setNameFormat("hwvtep-ha-task-%d").setUncaughtExceptionHandler(this).build();
         executorService = Executors.newSingleThreadScheduledExecutor(threadFact);
+        //TODO put metric for waiting job
     }
 
     public static HAJobScheduler getInstance() {
         return instance;
     }
 
+    public void setThreadPool(ExecutorService service) {
+        executorService = service;
+    }
+
     public void submitJob(Runnable runnable) {
         executorService.execute(runnable);
     }