Skip to content

Commit

Permalink
Ericsson#699 Reload nodes
Browse files Browse the repository at this point in the history
  • Loading branch information
Paul Chandler committed Oct 11, 2024
1 parent bed7775 commit 6f50bfb
Show file tree
Hide file tree
Showing 4 changed files with 15 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -153,6 +153,12 @@ private void createConnections() throws IOException
}
}

/***
* Creates a JMXconnection to the host.
* @param node
* @throws IOException
* @throws EcChronosException
*/
public void reconnect(final Node node) throws IOException, EcChronosException
{
try
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -244,9 +244,14 @@ public final DistributedNativeConnectionProviderImpl build()
LOG.info("Requesting Nodes List");
List<Node> nodesList = createNodesList(session);
LOG.info("Nodes list was created with success");
return new DistributedNativeConnectionProviderImpl(session, nodesList, this );
return new DistributedNativeConnectionProviderImpl(session, nodesList, this);
}

/**
* Creates a list of nodes based on the connection type, reads the node list from the database.
* @param session the connection information to the database
* @return list of nodes
*/
public List<Node> createNodesList(final CqlSession session)
{
List<Node> tmpNodeList = new ArrayList<>();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -142,7 +142,7 @@ public void close(final UUID nodeID) throws IOException
}

/**
* Add a node and create a JMXconnection
* Add a node and create a JMXconnection.
* @param node
* @throws IOException
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ public List<Node> getNodes()
}

/***
* Replaces the current node list with a new one
* Replaces the current node list with a new one.
* @param nodes
*/
@Override
Expand All @@ -81,7 +81,7 @@ public void setNodes(final List<Node> nodes)
}

/***
* Reloads the list of nodes from the database
* Reloads the list of nodes from the database.
* @return list of nodes
*/
@Override
Expand Down

0 comments on commit 6f50bfb

Please sign in to comment.