Distributed Session Management #7529

enonic · Oct 22, 2019 · 5066785 · 5066785
1 parent 9293229
commit 5066785
Showing 1 changed file with 47 additions and 1 deletion.
diff --git a/modules/core/core-ignite/src/main/java/com/enonic/xp/ignite/impl/IgniteCluster.java b/modules/core/core-ignite/src/main/java/com/enonic/xp/ignite/impl/IgniteCluster.java
@@ -14,7 +14,10 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.enonic.xp.cluster.Cluster;
 import com.enonic.xp.cluster.ClusterConfig;
+import com.enonic.xp.cluster.ClusterHealth;
+import com.enonic.xp.cluster.ClusterId;
 import com.enonic.xp.cluster.ClusterNode;
 import com.enonic.xp.cluster.ClusterNodes;
 import com.enonic.xp.ignite.impl.config.ConfigurationFactory;
@@ -28,6 +31,7 @@
 
 @Component(immediate = true, configurationPid = "com.enonic.xp.ignite")
 public class IgniteCluster
+    implements Cluster
 {
     private Ignite ignite;
 
@@ -71,6 +75,7 @@ public void activate( final BundleContext context, final IgniteSettings igniteSe
             thread.setContextClassLoader( classLoader );
         }
         context.registerService( Ignite.class, ignite, new Hashtable<>() );
+        // Register admin-client to use in e.g reporting
         context.registerService( IgniteAdminClient.class, new IgniteAdminClientImpl( this.ignite ), new Hashtable<>() );
     }
 
@@ -89,6 +94,48 @@ public void deactivate()
         this.ignite.close();
     }
 
+    @Override
+    public ClusterId getId()
+    {
+        return ClusterId.from( "ignite" );
+    }
+
+    @Override
+    public ClusterHealth getHealth()
+    {
+        return ClusterHealth.green();
+    }
+
+    @Override
+    public ClusterNodes getNodes()
+    {
+        try
+        {
+            return doGetNodes();
+        }
+        catch ( java.lang.IllegalStateException e )
+        {
+            return ClusterNodes.create().build();
+        }
+    }
+
+    @Override
+    public void enable()
+    {
+        // ignore
+    }
+
+    @Override
+    public void disable()
+    {
+        // ignore
+    }
+
+    @Override
+    public boolean isEnabled()
+    {
+        return this.reg != null;
+    }
 
     private ClusterNodes doGetNodes()
     {
@@ -104,7 +151,6 @@ private ClusterNodes doGetNodes()
         return builder.build();
     }
 
-
     @SuppressWarnings("unused")
     @Reference
     public void setClusterConfig( final ClusterConfig clusterConfig )