Package org.apache.activemq.broker

Interface Connector

All Superinterfaces:

org.apache.activemq.Service

All Known Implementing Classes:

ManagedTransportConnector, TransportConnector

public interface Connector
extends org.apache.activemq.Service

A connector creates and manages client connections that talk to the Broker.

Method Summary

Modifier and Type	Method	Description
int	connectionCount()	Deprecated, for removal: This API element is subject to removal in a future version.
org.apache.activemq.command.BrokerInfo	getBrokerInfo()
int	getConnectionCount()
URI	getConnectUri()
URI	getDiscoveryUri()
long	getMaxConnectionExceededCount()
int	getMaximumConsumersAllowedPerConnection()
int	getMaximumProducersAllowedPerConnection()
URI	getPublishableConnectURI()
ConnectorStatistics	getStatistics()
String	getUpdateClusterFilter()
URI	getUri()
boolean	isAllowLinkStealing()	If enabled, older connections with the same clientID are stopped
boolean	isAuditNetworkProducers()
boolean	isAutoStart()
boolean	isEnableStatusMonitor()
boolean	isRebalanceClusterClients()
boolean	isStarted()
boolean	isUpdateClusterClients()
boolean	isUpdateClusterClientsOnRemove()
void	resetStatistics()	Reset Connector statistics
void	updateClientClusterInfo()	Update all the connections with information about the connected brokers in the cluster

Methods inherited from interface org.apache.activemq.Service

start, stop

Method Detail

getBrokerInfo

org.apache.activemq.command.BrokerInfo getBrokerInfo()

Returns:

brokerInfo

getStatistics

ConnectorStatistics getStatistics()

Returns:

the statistics for this connector

resetStatistics

void resetStatistics()

Reset Connector statistics

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

@Deprecated(forRemoval=true)
int connectionCount()

Deprecated, for removal: This API element is subject to removal in a future version.

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

getMaxConnectionExceededCount

long getMaxConnectionExceededCount()

isAutoStart

boolean isAutoStart()

isStarted

boolean isStarted()

Returns:

true if connector is started

getConnectUri

URI getConnectUri()
           throws IOException,
                  URISyntaxException

Throws:

IOException

URISyntaxException

getPublishableConnectURI

URI getPublishableConnectURI()
                      throws Exception

Throws:

Exception

isEnableStatusMonitor

boolean isEnableStatusMonitor()

getUri

URI getUri()

getDiscoveryUri

URI getDiscoveryUri()

isAuditNetworkProducers

boolean isAuditNetworkProducers()

getMaximumProducersAllowedPerConnection

int getMaximumProducersAllowedPerConnection()

getMaximumConsumersAllowedPerConnection

int getMaximumConsumersAllowedPerConnection()

getConnectionCount

int getConnectionCount()