Package org.apache.activemq.broker.jmx
Class ManagedTransportConnection
- java.lang.Object
-
- org.apache.activemq.broker.TransportConnection
-
- org.apache.activemq.broker.jmx.ManagedTransportConnection
-
- All Implemented Interfaces:
Connection
,Service
,CommandVisitor
,Task
public class ManagedTransportConnection extends TransportConnection
A managed transport connection
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.broker.TransportConnection
broker, brokerConnectionStates, brokerInfo, brokerService, connector, dispatchQueue, dispatchStopped, taskRunner, transportException
-
-
Constructor Summary
Constructors Constructor Description ManagedTransportConnection(TransportConnector connector, Transport transport, Broker broker, TaskRunnerFactory factory, TaskRunnerFactory stopFactory, ManagementContext context, ObjectName connectorName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ObjectName
createObjectName(String type, String value)
Response
processAddConnection(ConnectionInfo info)
protected void
registerMBean(ObjectName name)
void
stopAsync()
protected void
unregisterMBean(ObjectName name)
-
Methods inherited from class org.apache.activemq.broker.TransportConnection
delayedStop, dispatch, dispatchAsync, dispatchSync, doMark, doStop, getActiveTransactionCount, getConnectionId, getConnector, getDispatchQueueSize, getDuplexNetworkConnectorId, getMessageAuthorizationPolicy, getOldestActiveTransactionDuration, getProducerBrokerExchangeIfExists, getProtocolVersion, getRemoteAddress, getRemoteWireFormatInfo, getStatistics, getStopped, getTransport, isActive, isBlocked, isBlockedCandidate, isConnected, isFaultTolerantConnection, isManageable, isMarkedBlockedCandidate, isMarkedCandidate, isNetworkConnection, isPendingStop, isSlow, isStarting, isStopping, iterate, listConnectionStates, lookupConnectionState, lookupConnectionState, lookupConnectionState, lookupConnectionState, lookupConnectionState, processAddConsumer, processAddDestination, processAddProducer, processAddSession, processBeginTransaction, processBrokerInfo, processBrokerSubscriptionInfo, processCommitTransactionOnePhase, processCommitTransactionTwoPhase, processConnectionControl, processConnectionError, processConsumerControl, processControlCommand, processDispatch, processEndTransaction, processFlush, processForgetTransaction, processKeepAlive, processMessage, processMessageAck, processMessageDispatch, processMessageDispatchNotification, processMessagePull, processPrepareTransaction, processProducerAck, processRecoverTransactions, processRemoveConnection, processRemoveConsumer, processRemoveDestination, processRemoveProducer, processRemoveSession, processRemoveSubscription, processRollbackTransaction, processShutdown, processWireFormat, registerConnectionState, service, serviceException, serviceExceptionAsync, serviceTransportException, setActive, setBlocked, setBlockedCandidate, setConnected, setDuplexNetworkConnectorId, setMarkedCandidate, setMessageAuthorizationPolicy, setSlow, start, stop, stopAsync, toString, unregisterConnectionState, updateClient
-
-
-
-
Constructor Detail
-
ManagedTransportConnection
public ManagedTransportConnection(TransportConnector connector, Transport transport, Broker broker, TaskRunnerFactory factory, TaskRunnerFactory stopFactory, ManagementContext context, ObjectName connectorName) throws IOException
- Throws:
IOException
-
-
Method Detail
-
stopAsync
public void stopAsync()
- Overrides:
stopAsync
in classTransportConnection
-
processAddConnection
public Response processAddConnection(ConnectionInfo info) throws Exception
- Specified by:
processAddConnection
in interfaceCommandVisitor
- Overrides:
processAddConnection
in classTransportConnection
- Throws:
Exception
-
registerMBean
protected void registerMBean(ObjectName name)
-
unregisterMBean
protected void unregisterMBean(ObjectName name)
-
createObjectName
protected ObjectName createObjectName(String type, String value) throws IOException
- Throws:
IOException
-
-