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 int
connectionCount()
BrokerInfo
getBrokerInfo()
ConnectorStatistics
getStatistics()
String
getUpdateClusterFilter()
boolean
isAllowLinkStealing()
If enabled, older connections with the same clientID are stoppedboolean
isRebalanceClusterClients()
boolean
isUpdateClusterClients()
boolean
isUpdateClusterClientsOnRemove()
void
updateClientClusterInfo()
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
-
-