Package org.apache.activemq.broker.jmx
Class ManagedTransportConnector
- java.lang.Object
-
- org.apache.activemq.broker.TransportConnector
-
- org.apache.activemq.broker.jmx.ManagedTransportConnector
-
- All Implemented Interfaces:
BrokerServiceAware
,Connector
,Service
public class ManagedTransportConnector extends TransportConnector
A managed transport connector which can create multiple managed connections as clients connect.
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.broker.TransportConnector
connections, statusDector
-
-
Constructor Summary
Constructors Constructor Description ManagedTransportConnector(ManagementContext context, ObjectName connectorName, TransportServer server)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description ManagedTransportConnector
asManagedConnector(MBeanServer mbeanServer, ObjectName connectorName)
protected Connection
createConnection(Transport transport)
protected static long
getNextConnectionId()
-
Methods inherited from class org.apache.activemq.broker.TransportConnector
addPeerBroker, asManagedConnector, connectionCount, createDiscoveryAgent, createTransportServer, getBroker, getBrokerInfo, getBrokerService, getConnectionControl, getConnections, getConnectUri, getDiscoveryAgent, getDiscoveryUri, getMaximumConsumersAllowedPerConnection, getMaximumProducersAllowedPerConnection, getMessageAuthorizationPolicy, getName, getPeerBrokers, getPublishableConnectString, getPublishableConnectURI, getPublishedAddressPolicy, getRootCause, getServer, getStatistics, getTaskRunnerFactory, getUpdateClusterFilter, getUri, isAllowLinkStealing, isAuditNetworkProducers, isDisableAsyncDispatch, isDisplayStackTrace, isEnableStatusMonitor, isRebalanceClusterClients, isUpdateClusterClients, isUpdateClusterClientsOnRemove, isWarnOnRemoteClose, onStarted, onStopped, removePeerBroker, setAllowLinkStealing, setAuditNetworkProducers, setBrokerInfo, setBrokerService, setDisableAsyncDispatch, setDiscoveryAgent, setDiscoveryUri, setDisplayStackTrace, setEnableStatusMonitor, setMaximumConsumersAllowedPerConnection, setMaximumProducersAllowedPerConnection, setMessageAuthorizationPolicy, setName, setPublishedAddressPolicy, setRebalanceClusterClients, setServer, setTaskRunnerFactory, setUpdateClusterClients, setUpdateClusterClientsOnRemove, setUpdateClusterFilter, setUri, setWarnOnRemoteClose, start, stop, toString, updateClientClusterInfo
-
-
-
-
Constructor Detail
-
ManagedTransportConnector
public ManagedTransportConnector(ManagementContext context, ObjectName connectorName, TransportServer server)
-
-
Method Detail
-
asManagedConnector
public ManagedTransportConnector asManagedConnector(MBeanServer mbeanServer, ObjectName connectorName) throws IOException, URISyntaxException
- Throws:
IOException
URISyntaxException
-
createConnection
protected Connection createConnection(Transport transport) throws IOException
- Overrides:
createConnection
in classTransportConnector
- Throws:
IOException
-
getNextConnectionId
protected static long getNextConnectionId()
-
-