feature[ats_Q9NLC]: Add thread to cluster startup

1 files changed, 16 insertions, 16 deletions

diff --git a/plugins/org.eclipse.osee.cluster.hazelcast/src/org/eclipse/osee/cluster/hazelcast/internal/ClusterServiceImpl.java b/plugins/org.eclipse.osee.cluster.hazelcast/src/org/eclipse/osee/cluster/hazelcast/internal/ClusterServiceImpl.java
index f31bd76d49e..0a782482dd4 100644
--- a/plugins/org.eclipse.osee.cluster.hazelcast/src/org/eclipse/osee/cluster/hazelcast/internal/ClusterServiceImpl.java
+++ b/plugins/org.eclipse.osee.cluster.hazelcast/src/org/eclipse/osee/cluster/hazelcast/internal/ClusterServiceImpl.java
@@ -129,22 +129,22 @@ public class ClusterServiceImpl implements ClusterService, InstanceManager {
    }
 
    public synchronized void start(final Map<String, Object> properties) {
-      //      thread = new Thread("Register Pending Rest Services") {
-      //         @Override
-      //         public void run() {
-      Config config = getConfiguration(properties);
-      instance = Hazelcast.init(config);
-      clusterProxy = new ClusterProxy(instance);
-      executor = new DistributedExecutorServiceImpl(instance);
-
-      String componentName = ClusterServiceUtils.getComponentName(properties);
-      String contextName = ClusterServiceUtils.getContextName(properties);
-      eventNotifier = new ClusterEventNotifier(componentName, contextName, getEventService());
-      registerEventListeners();
-      eventNotifier.notifyRegistration();
-      //         }
-      //      };
-      //      thread.start();
+      thread = new Thread("Register Pending Rest Services") {
+         @Override
+         public void run() {
+            Config config = getConfiguration(properties);
+            instance = Hazelcast.init(config);
+            clusterProxy = new ClusterProxy(instance);
+            executor = new DistributedExecutorServiceImpl(instance);
+
+            String componentName = ClusterServiceUtils.getComponentName(properties);
+            String contextName = ClusterServiceUtils.getContextName(properties);
+            eventNotifier = new ClusterEventNotifier(componentName, contextName, getEventService());
+            registerEventListeners();
+            eventNotifier.notifyRegistration();
+         }
+      };
+      thread.start();
    }
 
    public synchronized void stop(Map<String, Object> properties) {