Ericsson#699 Reload nodes

paulchandler · Oct 11, 2024 · bed7775 · bed7775
1 parent e049899
commit bed7775
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 4 deletions.
diff --git a/...s/cassandra/ecchronos/connection/impl/providers/DistributedJmxConnectionProviderImpl.java b/...s/cassandra/ecchronos/connection/impl/providers/DistributedJmxConnectionProviderImpl.java
@@ -140,12 +140,21 @@ public void close(final UUID nodeID) throws IOException
     {
         myJMXConnections.get(nodeID).close();
     }
+
+    /**
+     * Add a node and create a JMXconnection
+     * @param node
+     * @throws IOException
+     */
     @Override
     public void add(final Node node) throws IOException
     {
-        try {
+        try
+        {
             myDistributedJmxBuilder.reconnect(node);
-        } catch (EcChronosException e) {
+        }
+        catch (EcChronosException e)
+        {
             throw new RuntimeException(e);
         }
 

diff --git a/...assandra/ecchronos/connection/impl/providers/DistributedNativeConnectionProviderImpl.java b/...assandra/ecchronos/connection/impl/providers/DistributedNativeConnectionProviderImpl.java
@@ -69,13 +69,24 @@ public List<Node> getNodes()
     {
         return myNodes;
     }
+
+    /***
+     * Replaces the current node list with a new one
+     * @param nodes
+     */
     @Override
-    public void setNodes(List<Node> nodes)
+    public void setNodes(final List<Node> nodes)
     {
          myNodes = nodes;
     }
+
+    /***
+     * Reloads the list of nodes from the database
+     * @return list of nodes
+     */
     @Override
-    public List<Node> reloadNodes(){
+    public List<Node> reloadNodes()
+    {
         return myDistributedNativeBuilder.createNodesList(mySession);
     }