Class ConnectorView

java.lang.Object

org.apache.activemq.broker.jmx.ConnectorView

All Implemented Interfaces:

ConnectorViewMBean, org.apache.activemq.Service

public class ConnectorView
extends Object
implements ConnectorViewMBean

Constructor Summary

Constructors

Constructor	Description
ConnectorView(Connector connector)

Method Summary

Modifier and Type	Method	Description
int	connectionCount()	Returns the number of current connections
void	disableStatistics()	disable statistics gathering
void	enableStatistics()	enable statistics gathering
org.apache.activemq.command.BrokerInfo	getBrokerInfo()
String	getBrokerInfoString()
String	getBrokerName()
String	getBrokerURL()
int	getConnectionCount()	Returns the number of current connections
String	getConnectURI()
String	getDiscoveryURI()
long	getMaxConnectionExceededCount()
int	getMaximumConsumersAllowedPerConnection()	Returns the number of maximum consumers allowed per-connection
int	getMaximumProducersAllowedPerConnection()	Returns the number of maximum producers allowed per-connection
String	getName()
String	getPublishableConnectURI()
String	getUpdateClusterFilter()
String	getURI()
boolean	isAllowLinkStealingEnabled()	Returns true if link stealing is enabled on this Connector
boolean	isAuditNetworkProducers()
boolean	isAutoStart()
boolean	isEnableStatusMonitor()	Returns true the status monitor is enabled
boolean	isRebalanceClusterClients()	Returns true if rebalancing cluster clients is enabled
boolean	isStarted()
boolean	isStatisticsEnabled()	Returns true if statistics is enabled
boolean	isUpdateClusterClients()	Returns true if updating cluster client URL is enabled
boolean	isUpdateClusterClientsOnRemove()	Returns true if updating cluster client URL when brokers are removed is enabled
void	resetStatistics()	Resets the statistics
void	start()
void	stop()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ConnectorView

public ConnectorView(Connector connector)

Method Details

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.Service

Throws:

Exception

getBrokerName

public String getBrokerName()

Specified by:

getBrokerName in interface ConnectorViewMBean

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.activemq.Service

Throws:

Exception

getBrokerURL

public String getBrokerURL()

getBrokerInfo

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

resetStatistics

public void resetStatistics()

Resets the statistics

Specified by:

resetStatistics in interface ConnectorViewMBean

enableStatistics

public void enableStatistics()

enable statistics gathering

Specified by:

enableStatistics in interface ConnectorViewMBean

disableStatistics

public void disableStatistics()

disable statistics gathering

Specified by:

disableStatistics in interface ConnectorViewMBean

isStatisticsEnabled

public boolean isStatisticsEnabled()

Returns true if statistics is enabled

Specified by:

isStatisticsEnabled in interface ConnectorViewMBean

Returns:

true if statistics is enabled

connectionCount

public int connectionCount()

Returns the number of current connections

Specified by:

connectionCount in interface ConnectorViewMBean

isUpdateClusterClients

public boolean isUpdateClusterClients()

Returns true if updating cluster client URL is enabled

Specified by:

isUpdateClusterClients in interface ConnectorViewMBean

Returns:

true if update cluster client URL is enabled

isRebalanceClusterClients

public boolean isRebalanceClusterClients()

Returns true if rebalancing cluster clients is enabled

Specified by:

isRebalanceClusterClients in interface ConnectorViewMBean

Returns:

true if rebalance cluster clients is enabled

isUpdateClusterClientsOnRemove

public boolean isUpdateClusterClientsOnRemove()

Returns true if updating cluster client URL when brokers are removed is enabled

Specified by:

isUpdateClusterClientsOnRemove in interface ConnectorViewMBean

Returns:

true if update cluster client URL when brokers are removed is enabled

getUpdateClusterFilter

public String getUpdateClusterFilter()

Specified by:

getUpdateClusterFilter in interface ConnectorViewMBean

Returns:

The comma separated string of regex patterns to match broker names for cluster client updates

isAllowLinkStealingEnabled

public boolean isAllowLinkStealingEnabled()

Description copied from interface: ConnectorViewMBean

Returns true if link stealing is enabled on this Connector

Specified by:

isAllowLinkStealingEnabled in interface ConnectorViewMBean

Returns:

true if link stealing is enabled.

getMaxConnectionExceededCount

public long getMaxConnectionExceededCount()

Specified by:

getMaxConnectionExceededCount in interface ConnectorViewMBean

Returns:

The number of occurrences the max connection count has been exceed

isAutoStart

public boolean isAutoStart()

Specified by:

isAutoStart in interface ConnectorViewMBean

Returns:

true if transport connector auto start is enabled

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ConnectorViewMBean

Returns:

true if transport connector is started

getConnectURI

public String getConnectURI()

Specified by:

getConnectURI in interface ConnectorViewMBean

Returns:

The direct connect uri

getPublishableConnectURI

public String getPublishableConnectURI()

Specified by:

getPublishableConnectURI in interface ConnectorViewMBean

Returns:

The publishable connect uri

getBrokerInfoString

public String getBrokerInfoString()

Specified by:

getBrokerInfoString in interface ConnectorViewMBean

isEnableStatusMonitor

public boolean isEnableStatusMonitor()

Returns true the status monitor is enabled

Specified by:

isEnableStatusMonitor in interface ConnectorViewMBean

Returns:

true if status monitor is enabled

getURI

public String getURI()

Specified by:

getURI in interface ConnectorViewMBean

getDiscoveryURI

public String getDiscoveryURI()

Specified by:

getDiscoveryURI in interface ConnectorViewMBean

isAuditNetworkProducers

public boolean isAuditNetworkProducers()

Specified by:

isAuditNetworkProducers in interface ConnectorViewMBean

getMaximumProducersAllowedPerConnection

public int getMaximumProducersAllowedPerConnection()

Returns the number of maximum producers allowed per-connection

Specified by:

getMaximumProducersAllowedPerConnection in interface ConnectorViewMBean

getMaximumConsumersAllowedPerConnection

public int getMaximumConsumersAllowedPerConnection()

Returns the number of maximum consumers allowed per-connection

Specified by:

getMaximumConsumersAllowedPerConnection in interface ConnectorViewMBean

getConnectionCount

public int getConnectionCount()

Returns the number of current connections

Specified by:

getConnectionCount in interface ConnectorViewMBean

getName

public String getName()

Specified by:

getName in interface ConnectorViewMBean