Package org.apache.activemq.artemis.cli.commands.check

Class ClusterNodeVerifier

java.lang.Object

org.apache.activemq.artemis.cli.commands.check.ClusterNodeVerifier

All Implemented Interfaces:

AutoCloseable

public class ClusterNodeVerifier
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClusterNodeVerifier.TopologyItem

Constructor Summary

Constructors

Constructor	Description
ClusterNodeVerifier(String uri, String user, String password)
ClusterNodeVerifier(String uri, String user, String password, long variance)

Method Summary

Modifier and Type	Method	Description
void	close()
String	compareTopology(Map<String,ClusterNodeVerifier.TopologyItem> mainTopology, Map<String,ClusterNodeVerifier.TopologyItem> compareTopology)
protected long	fetchMainTime()
protected org.apache.activemq.artemis.json.JsonArray	fetchMainTopology()
protected long	fetchTime(String uri)
protected org.apache.activemq.artemis.json.JsonArray	fetchTopology(String uri)
protected Long[]	fetchTopologyTime(Map<String,ClusterNodeVerifier.TopologyItem> topologyItemMap)
protected String	getNodeID()
ClusterNodeVerifier	open()
boolean	verify(ActionContext context)
protected void	verifyTime(ActionContext context, Map<String,ClusterNodeVerifier.TopologyItem> mainTopology, AtomicBoolean verificationResult, boolean supportTime)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterNodeVerifier

public ClusterNodeVerifier(String uri,
                           String user,
                           String password)

ClusterNodeVerifier

public ClusterNodeVerifier(String uri,
                           String user,
                           String password,
                           long variance)

Method Detail

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

open

public ClusterNodeVerifier open()
                         throws Exception

Throws:

Exception

verify

public boolean verify(ActionContext context)
               throws Exception

Throws:

Exception

verifyTime

protected void verifyTime(ActionContext context,
                          Map<String,ClusterNodeVerifier.TopologyItem> mainTopology,
                          AtomicBoolean verificationResult,
                          boolean supportTime)

fetchTopologyTime

protected Long[] fetchTopologyTime(Map<String,ClusterNodeVerifier.TopologyItem> topologyItemMap)

compareTopology

public String compareTopology(Map<String,ClusterNodeVerifier.TopologyItem> mainTopology,
                              Map<String,ClusterNodeVerifier.TopologyItem> compareTopology)

getNodeID

protected String getNodeID()
                    throws Exception

Throws:

Exception

fetchMainTime

protected long fetchMainTime()
                      throws Exception

Throws:

Exception

fetchTime

protected long fetchTime(String uri)
                  throws Exception

Throws:

Exception

fetchMainTopology

protected org.apache.activemq.artemis.json.JsonArray fetchMainTopology()
                                                                throws Exception

Throws:

Exception

fetchTopology

protected org.apache.activemq.artemis.json.JsonArray fetchTopology(String uri)
                                                            throws Exception

Throws:

Exception