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
- Version:
- $Revision: 1.1 $
Methods inherited from class org.apache.activemq.broker.TransportConnection |
dispatch, dispatchAsync, dispatchSync, doMark, getConnectionId, getConnector, getDispatchQueueSize, getMessageAuthorizationPolicy, getProtocolVersion, getRemoteAddress, getStatistics, isActive, isBlocked, isBlockedCandidate, isConnected, isManageable, isMarkedBlockedCandidate, isMarkedCandidate, isNetworkConnection, isPendingStop, isSlow, isStarting, 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, setMarkedCandidate, setMessageAuthorizationPolicy, setPendingStop, setSlow, setStarting, start, stop, stopAsync, toString, unregisterConnectionState |
ManagedTransportConnection
public ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
ManagementContext context,
ObjectName connectorName)
throws IOException
- Throws:
IOException
doStop
public void doStop()
throws Exception
- Overrides:
doStop
in class TransportConnection
- Throws:
Exception
setConnectionId
public void setConnectionId(String connectionId)
throws IOException
- Sets the connection ID of this connection. On startup this connection ID
is set to an incrementing counter; once the client registers it is set to
the clientID of the JMS client.
- Throws:
IOException
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)
createByAddressObjectName
protected ObjectName createByAddressObjectName(String type,
String value)
throws IOException
- Throws:
IOException
createByClientIdObjectName
protected ObjectName createByClientIdObjectName(String value)
throws IOException
- Throws:
IOException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.