Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorrescobar2011-09-20 23:22:03 -0400
committerRyan D. Brooks2011-09-20 23:22:03 -0400
commitc07e330e17fbb390a528c16088aeba702c4a8219 (patch)
treecec58faa04f3ae1b66499a16a6486ea4b58c8f9a /plugins/org.eclipse.osee.cluster.hazelcast
parentf3811cbac50e33d2e55d75ab0760e6312d843371 (diff)
downloadorg.eclipse.osee-c07e330e17fbb390a528c16088aeba702c4a8219.tar.gz
org.eclipse.osee-c07e330e17fbb390a528c16088aeba702c4a8219.tar.xz
org.eclipse.osee-c07e330e17fbb390a528c16088aeba702c4a8219.zip
feature[ats_Q9NLC]: Add thread to cluster startup
Diffstat (limited to 'plugins/org.eclipse.osee.cluster.hazelcast')
-rw-r--r--plugins/org.eclipse.osee.cluster.hazelcast/src/org/eclipse/osee/cluster/hazelcast/internal/ClusterServiceImpl.java32
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) {

Back to the top