public interface ClusterNodeMBean
Modifier and Type | Method and Description |
---|---|
void |
down(java.lang.String address)
Send command to DOWN the node specified by 'address'.
|
java.lang.String |
getClusterStatus() |
java.lang.String |
getLeader()
Get the address of the current leader.
|
java.lang.String |
getMembers()
Comma separated addresses of member nodes, sorted in the cluster ring order.
|
java.lang.String |
getMemberStatus()
Member status for this node.
|
java.lang.String |
getUnreachable()
Comma separated addresses of unreachable member nodes.
|
boolean |
isAvailable()
Returns true if the node is not unreachable and not
Down
and not Removed . |
boolean |
isSingleton()
Does the cluster consist of only one member?
|
void |
join(java.lang.String address)
Try to join this cluster node with the node specified by 'address'.
|
void |
leave(java.lang.String address)
Send command to issue state transition to LEAVING for the node specified by 'address'.
|
java.lang.String getMemberStatus()
java.lang.String getMembers()
akka.tcp://actor-system-name@hostname:port
java.lang.String getUnreachable()
akka.tcp://actor-system-name@hostname:port
java.lang.String getClusterStatus()
java.lang.String getLeader()
akka.tcp://actor-system-name@hostname:port
boolean isSingleton()
boolean isAvailable()
Down
and not Removed
.void join(java.lang.String address)
akka.tcp://actor-system-name@hostname:port
.
A 'Join(thisNodeAddress)' command is sent to the node to join.address
- (undocumented)void leave(java.lang.String address)
akka.tcp://actor-system-name@hostname:port
address
- (undocumented)void down(java.lang.String address)
akka.tcp://actor-system-name@hostname:port
address
- (undocumented)