public class ClusterConnectionControlImpl extends AbstractControl implements ClusterConnectionControl
storageManager| Constructor and Description |
|---|
ClusterConnectionControlImpl(ClusterConnection clusterConnection,
StorageManager storageManager,
ClusterConnectionConfiguration configuration) |
| Modifier and Type | Method and Description |
|---|---|
protected MBeanAttributeInfo[] |
fillMBeanAttributeInfo() |
protected MBeanOperationInfo[] |
fillMBeanOperationInfo() |
String |
getAddress()
Returns the address used by this cluster connection.
|
Map<String,Object> |
getBridgeMetrics(String nodeId)
The bridge metrics for the given node in the cluster connection
The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker.
|
String |
getDiscoveryGroupName()
Returns the name of the discovery group used by this cluster connection.
|
int |
getMaxHops()
Returns the maximum number of hops used by this cluster connection.
|
String |
getMessageLoadBalancingType()
Return the type of message load balancing strategy this bridge will use.
|
long |
getMessagesAcknowledged()
The messagesAcknowledged counter is the number of messages actually received by a remote broker for all
bridges in this cluster connection
This is a cumulative total and the number of outstanding pending messages for the cluster connection
can be computed by subtracting messagesAcknowledged from messagesPendingAcknowledgement.
|
long |
getMessagesPendingAcknowledgement()
The messagesPendingAcknowledgement counter is incremented when any bridge in the cluster connection has
forwarded a message and is waiting acknowledgement from the other broker.
|
Map<String,Object> |
getMetrics()
The current metrics for this cluster connection (aggregate over all bridges to other nodes)
The messagesPendingAcknowledgement counter is incremented when any bridge in the cluster connection has
forwarded a message and is waiting acknowledgement from the other broker.
|
String |
getName()
Returns the configuration name of this cluster connection.
|
String |
getNodeID()
Returns the node ID used by this cluster connection.
|
Map<String,String> |
getNodes()
Returns a map of the nodes connected to this cluster connection.
|
long |
getRetryInterval()
Returns the connection retry interval used by this cluster connection.
|
String[] |
getStaticConnectors()
Returns the list of static connectors
|
String |
getStaticConnectorsAsJSON()
Returns the list of static connectors as JSON
|
String |
getTopology()
Return the Topology that this Cluster Connection knows about
|
boolean |
isDuplicateDetection()
Return whether this cluster connection use duplicate detection.
|
boolean |
isStarted()
Returns
true if this component is started, false else. |
void |
start()
Starts this component.
|
void |
stop()
Stops this component.
|
blockOnIO, clearIO, getMBeanInfo, sendMessage, tcclCall, tcclInvokecacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementationpublic ClusterConnectionControlImpl(ClusterConnection clusterConnection, StorageManager storageManager, ClusterConnectionConfiguration configuration) throws Exception
Exceptionpublic String getAddress()
ClusterConnectionControlgetAddress in interface ClusterConnectionControlpublic String getDiscoveryGroupName()
ClusterConnectionControlgetDiscoveryGroupName in interface ClusterConnectionControlpublic int getMaxHops()
ClusterConnectionControlgetMaxHops in interface ClusterConnectionControlpublic String getName()
ClusterConnectionControlgetName in interface ClusterConnectionControlpublic long getRetryInterval()
ClusterConnectionControlgetRetryInterval in interface ClusterConnectionControlpublic String getNodeID()
ClusterConnectionControlgetNodeID in interface ClusterConnectionControlpublic String[] getStaticConnectors()
ClusterConnectionControlgetStaticConnectors in interface ClusterConnectionControlpublic String getStaticConnectorsAsJSON() throws Exception
ClusterConnectionControlgetStaticConnectorsAsJSON in interface ClusterConnectionControlExceptionpublic boolean isDuplicateDetection()
ClusterConnectionControlisDuplicateDetection in interface ClusterConnectionControlpublic String getMessageLoadBalancingType()
ClusterConnectionControlgetMessageLoadBalancingType in interface ClusterConnectionControlpublic String getTopology()
ClusterConnectionControlgetTopology in interface ClusterConnectionControlpublic Map<String,String> getNodes() throws Exception
ClusterConnectionControlgetNodes in interface ClusterConnectionControlExceptionpublic boolean isStarted()
ActiveMQComponentControltrue if this component is started, false else.isStarted in interface ActiveMQComponentControlpublic void start()
throws Exception
ActiveMQComponentControlstart in interface ActiveMQComponentControlExceptionpublic void stop()
throws Exception
ActiveMQComponentControlstop in interface ActiveMQComponentControlExceptionprotected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo in class AbstractControlprotected MBeanAttributeInfo[] fillMBeanAttributeInfo()
fillMBeanAttributeInfo in class AbstractControlpublic long getMessagesPendingAcknowledgement()
ClusterConnectionControlgetMessagesPendingAcknowledgement in interface ClusterConnectionControlpublic long getMessagesAcknowledged()
ClusterConnectionControlgetMessagesAcknowledged in interface ClusterConnectionControlpublic Map<String,Object> getMetrics()
ClusterConnectionControlgetMetrics in interface ClusterConnectionControlpublic Map<String,Object> getBridgeMetrics(String nodeId)
ClusterConnectionControlgetBridgeMetrics in interface ClusterConnectionControlCopyright © 2019 JBoss by Red Hat. All rights reserved.