Introduce DistributedJmxProxy and DistributedJmxProxyFactory (#727)

Ericsson · Oct 1, 2024 · 785002f · 785002f
1 parent 64c8617
commit 785002f
Show file tree

Hide file tree

Showing 22 changed files with 1,678 additions and 4 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -2,6 +2,7 @@
 
 ## Version 1.0.0 (Not yet Released)
 
+* Create DistributedJmxProxy and DistributedJmxProxyFactory - Issue #715
 * Create a New Maven Module "utils" for Common Code Reuse - Issue #720
 * Implement ReplicationStateImpl to Manage and Cache Token Range to Replica Mappings - Issue #719
 * Implement NodeResolverImpl to Resolve Nodes by IP Address and UUID - Issue #718

diff --git a/...om/ericsson/bss/cassandra/ecchronos/application/providers/AgentJmxConnectionProvider.java b/...om/ericsson/bss/cassandra/ecchronos/application/providers/AgentJmxConnectionProvider.java
@@ -133,6 +133,18 @@ public JMXConnector getJmxConnector(final UUID nodeID)
         return myDistributedJmxConnectionProviderImpl.getJmxConnector(nodeID);
     }
 
+    /**
+     * validate if the given JMXConnector is available.
+     *
+     * @param jmxConnector
+     *            The jmxConnector to validate
+     * @return A boolean representing the node's connection status.
+     */
+    @Override
+    public boolean isConnected(final JMXConnector jmxConnector)
+    {
+        return myDistributedJmxConnectionProviderImpl.isConnected(jmxConnector);
+    }
     /**
      * Closes the JMX connection associated with the specified node ID.
      *

diff --git a/...n/java/com/ericsson/bss/cassandra/ecchronos/application/spring/RetrySchedulerService.java b/...n/java/com/ericsson/bss/cassandra/ecchronos/application/spring/RetrySchedulerService.java
@@ -62,7 +62,6 @@
 @Service
 public final class RetrySchedulerService implements DisposableBean
 {
-
     private static final Logger LOG = LoggerFactory.getLogger(RetrySchedulerService.class);
     private static final String COLUMN_NODE_ID = "node_id";
     private static final String COLUMN_NODE_STATUS = "node_status";

diff --git a/...s/cassandra/ecchronos/connection/impl/providers/DistributedJmxConnectionProviderImpl.java b/...s/cassandra/ecchronos/connection/impl/providers/DistributedJmxConnectionProviderImpl.java
@@ -48,7 +48,15 @@ public DistributedJmxConnectionProviderImpl(
         myJMXConnections = jmxConnections;
     }
 
-    private static boolean isConnected(final JMXConnector jmxConnector)
+    /**
+     * validate if the given JMXConnector is available.
+     *
+     * @param jmxConnector
+     *            The jmxConnector to validate
+     * @return A boolean representing the node's connection status.
+     */
+    @Override
+    public boolean isConnected(final JMXConnector jmxConnector)
     {
         try
         {

diff --git a/...ava/com/ericsson/bss/cassandra/ecchronos/connection/DistributedJmxConnectionProvider.java b/...ava/com/ericsson/bss/cassandra/ecchronos/connection/DistributedJmxConnectionProvider.java
@@ -27,6 +27,8 @@ public interface DistributedJmxConnectionProvider extends Closeable
 
     JMXConnector getJmxConnector(UUID nodeID);
 
+    boolean isConnected(JMXConnector jmxConnector);
+
     @Override
     default void close() throws IOException
     {

diff --git a/core.impl/pom.xml b/core.impl/pom.xml
@@ -41,6 +41,12 @@
             <version>${project.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.ericsson.bss.cassandra.ecchronos</groupId>
+            <artifactId>data</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
         <!-- Cassandra driver -->
         <dependency>
             <groupId>com.datastax.oss</groupId>