public interface RhinoHousekeepingMBean
Administration MBean for operator driven Rhino housekeeping.
Modifier and Type | Field and Description |
---|---|
static String |
OBJECT_NAME |
Modifier and Type | Method and Description |
---|---|
int[] |
getAllClusterNodes()
Get the node IDs of all cluster members, including quorum nodes.
|
ObjectName |
getClusterHousekeeping()
Get a
NodeHousekeepingMBean for the cluster. |
TabularData |
getClusterState()
Queries current cluster state returning a summary of the state of each cluster member.
|
TabularData |
getDomainConfig()
Returns the current domain configuration.
|
int[] |
getEventRouterNodes()
Get the node IDs of all event processing nodes in the cluster.
|
ObjectName |
getNodeHousekeeping(int nodeID)
Get a
NodeHousekeepingMBean for a single cluster node. |
int |
getNodeID()
Get the node ID of this node.
|
String[] |
getPersistenceResources()
Get the names of the persistence resources that have been defined for the node.
|
int[] |
getQuorumNodes()
Get the node IDs of all quorum nodes in the cluster.
|
TabularData |
getReplicatedMemDBStripingConfig()
Returns the current MemDB striping configuration for replicated MemDB instances.
|
int |
getSnapshotPort()
Returns the port the currently connected node uses for streaming snapshot data.
|
CompositeData |
getVersion()
Returns Rhino version information as CompositeData.
|
boolean |
isReady(int nodeID)
Test whether a node is ready to receive management commands.
|
void |
markAllActivitiesForRemoval(String entityName,
int[] nodeIDs)
Mark all activities belonging to a resource adaptor entity on the specified nodes for removal.
|
void |
removeAllSbbs(ServiceID serviceID,
int[] nodeIDs)
Remove all SBB entities from a service on the specified nodes.
|
static final String OBJECT_NAME
int getNodeID()
Get the node ID of this node. This method may be used by a management client to determine which Rhino node it is communicating with.
int[] getEventRouterNodes()
Get the node IDs of all event processing nodes in the cluster.
int[] getQuorumNodes()
Get the node IDs of all quorum nodes in the cluster.
int[] getAllClusterNodes()
Get the node IDs of all cluster members, including quorum nodes.
ObjectName getClusterHousekeeping() throws ManagementException
Get a NodeHousekeepingMBean
for the cluster.
This method returns a special instance of NodeHousekeepingMBean
that operates on the entire cluster rather than a single node.
ManagementException
- if an internal error occurs.ObjectName getNodeHousekeeping(int nodeID) throws InvalidArgumentException, ManagementException
Get a NodeHousekeepingMBean
for a single cluster node.
This method returns the Object Name of a NodeHousekeepingMBean
that operates on a single node.
The specified node does not have to be a current member of the cluster, it may represent a failed or yet to join node.
Invocations made against the returned MBean will fail however if the specified node is not a member of the cluster when the invocation occurs.
nodeID
- node ID of the node.InvalidArgumentException
- if nodeID
is invalid.ManagementException
- if an internal error occurs.void markAllActivitiesForRemoval(String entityName, int[] nodeIDs) throws NullPointerException, UnrecognizedResourceAdaptorEntityException, InvalidStateException, ManagementException
Mark all activities belonging to a resource adaptor entity on the specified nodes for removal.
Caution: This method irrevocably removes application state.
Used for force-ending activities from a deactivating resource adaptor.
All activities belonging to the specified resource adaptor entity on the specified nodes will be marked as requiring removal and then ended during the next iteration of Rhino’s periodic query-liveness scan.
The resource adaptor entity must be in the deactivating state on the given nodes.
entityName
- Resource Adaptor entity name of the RA entitynodeIDs
- the node IDs of the nodes to remove activities from.
May be zero-length, in which case all current event-router cluster nodes are targeted.NullPointerException
- if either argument is null
.UnrecognizedResourceAdaptorEntityException
- if the resource adaptor entity is unknown.InvalidStateException
- if the resource adaptor entity is not in the Stopping or Inactive state, or the SLEE is not in the Stopping or Stopped state, on the specified nodes.ManagementException
- if an internal error occurs.void removeAllSbbs(ServiceID serviceID, int[] nodeIDs) throws NullPointerException, UnrecognizedServiceException, InvalidStateException, ManagementException
Remove all SBB entities from a service on the specified nodes.
Caution: This method irrevocably removes application state.
Used for forcibly removing remaining SBBs from a deactivating service.
serviceID
- component ID of the service from which all SBBs should be removed.nodeIDs
- the node IDs of the nodes to remove SBB entities from.
May be zero-length, in which case all current event-router cluster nodes are targeted.NullPointerException
- if either argument is null
.UnrecognizedServiceException
- if the service is unknown.InvalidStateException
- if the service is not in the Stopping or Inactive state, or the SLEE is not in the Stopping or Stopped state, on the specified nodes.ManagementException
- if an internal error occurs.boolean isReady(int nodeID) throws ManagementException
Test whether a node is ready to receive management commands.
nodeID
- node ID of the node.ManagementException
- if an internal error occurs.String[] getPersistenceResources() throws ManagementException
Get the names of the persistence resources that have been defined for the node.
ManagementException
- if an internal error occurs.TabularData getClusterState() throws ManagementException
Queries current cluster state returning a summary of the state of each cluster member.
The cluster state is returned in TabularData
format - one row is returned per cluster member.
Each row contains the following information:
Field | Open Type | Description |
---|---|---|
node-id |
Integer |
Rhino cluster node id |
host |
String |
Name of the host on which the node is running |
node-type |
String |
Type of node, either "event-router" or "quorum" |
start-time |
Date |
Start time of the cluster node |
up-time |
Long |
Time the cluster node has been running in milliseconds |
slee-state |
String |
SLEE state |
active-alarms |
Integer |
Number of active alarms on the cluster node |
TabularData
containing node status information. @throws ManagementException if an internal error occurs.ManagementException
TabularData getDomainConfig() throws ManagementException
Returns the current domain configuration.
The domain config is returned in TabularData
format - one row is returned per domain.
Each row contains the following information:
Field | Open Type | Description |
---|---|---|
domain |
String |
Domain name |
memdb-resources |
String[] |
Array of memdb resource names |
ah-resources |
String[] |
Array of AH resource names |
nodes |
Integer[] |
Nodes associated with this domain |
TabularData
containing node status information. @throws ManagementException if an internal error occurs.ManagementException
TabularData getReplicatedMemDBStripingConfig() throws ManagementException
Returns the current MemDB striping configuration for replicated MemDB instances.
The striping config is returned in TabularData
format - one row is returned per replicated MemDB instance.
Each row contains the following information:
Field | Open Type | Description |
---|---|---|
memdb-resource |
String |
Memdb resource name |
stripe-count |
Integer |
The stripe count |
stripe-offset |
Integer |
The stripe offset |
TabularData
containing node striping configuration information. @throws ManagementException if an internal error occurs.ManagementException
CompositeData getVersion() throws AttributeNotFoundException, ManagementException
Returns Rhino version information as CompositeData.
The CompositeData has the following fields, which are all of type String
:
Product
Version
Release
Build
Revision
CompositeData
containing detailed Rhino version informationAttributeNotFoundException
- if the MBean implementation does not support this method (Rhino versions prior to 2.2 don’t)ManagementException
- if an internal error occursint getSnapshotPort() throws ManagementException
Returns the port the currently connected node uses for streaming snapshot data.
ManagementException