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, connector, dispatchQueue, dispatchStopped, taskRunner, transportException

Constructor Summary

Constructors

Constructor and Description
ManagedTransportConnection(TransportConnector connector, Transport transport, Broker broker, TaskRunnerFactory factory, TaskRunnerFactory stopFactory, ManagementContext context, ObjectName connectorName)

Method Summary

Methods

Modifier and Type	Method and 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, 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, setPendingStop, setSlow, setStarting, start, stop, stopAsync, toString, unregisterConnectionState, updateClient

Methods inherited from class java.lang.Object

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

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 class TransportConnection

processAddConnection

public Response processAddConnection(ConnectionInfo info)
                              throws Exception

Specified by:

processAddConnection in interface CommandVisitor

Overrides:

processAddConnection in class TransportConnection

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