Package org.apache.activemq.broker
Interface Connector
-
- All Superinterfaces:
Service
- All Known Implementing Classes:
ManagedTransportConnector,TransportConnector
public interface Connector extends Service
A connector creates and manages client connections that talk to the Broker.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description intconnectionCount()BrokerInfogetBrokerInfo()ConnectorStatisticsgetStatistics()StringgetUpdateClusterFilter()booleanisAllowLinkStealing()If enabled, older connections with the same clientID are stoppedbooleanisRebalanceClusterClients()booleanisUpdateClusterClients()booleanisUpdateClusterClientsOnRemove()voidupdateClientClusterInfo()Update all the connections with information about the connected brokers in the cluster
-
-
-
Method Detail
-
getBrokerInfo
BrokerInfo getBrokerInfo()
- Returns:
- brokerInfo
-
getStatistics
ConnectorStatistics getStatistics()
- Returns:
- the statistics for this connector
-
isUpdateClusterClients
boolean isUpdateClusterClients()
- Returns:
- true if update client connections when brokers leave/join a cluster
-
isRebalanceClusterClients
boolean isRebalanceClusterClients()
- Returns:
- true if clients should be re-balanced across the cluster
-
updateClientClusterInfo
void updateClientClusterInfo()
Update all the connections with information about the connected brokers in the cluster
-
isUpdateClusterClientsOnRemove
boolean isUpdateClusterClientsOnRemove()
- Returns:
- true if clients should be updated when a broker is removed from a broker
-
connectionCount
int connectionCount()
-
isAllowLinkStealing
boolean isAllowLinkStealing()
If enabled, older connections with the same clientID are stopped- Returns:
- true/false if link stealing is enabled
-
getUpdateClusterFilter
String getUpdateClusterFilter()
- Returns:
- The comma separated string of regex patterns to match broker names for cluster client updates
-
-