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
Methods inherited from class org.apache.activemq.broker.TransportConnection |
delayedStop, dispatch, dispatchAsync, dispatchSync, doMark, getConnectionId, getConnector, getDispatchQueueSize, getDuplexNetworkConnectorId, getMessageAuthorizationPolicy, getProtocolVersion, getRemoteAddress, getStatistics, getStopped, isActive, isBlocked, isBlockedCandidate, isConnected, isFaultTolerantConnection, 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, 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 |
ManagedTransportConnection
public ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
ManagementContext context,
javax.management.ObjectName connectorName)
throws java.io.IOException
- Throws:
java.io.IOException
doStop
public void doStop()
throws java.lang.Exception
- Overrides:
doStop
in class TransportConnection
- Throws:
java.lang.Exception
setConnectionId
public void setConnectionId(java.lang.String connectionId)
throws java.io.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:
java.io.IOException
processAddConnection
public Response processAddConnection(ConnectionInfo info)
throws java.lang.Exception
- Specified by:
processAddConnection
in interface CommandVisitor
- Overrides:
processAddConnection
in class TransportConnection
- Throws:
java.lang.Exception
registerMBean
protected void registerMBean(javax.management.ObjectName name)
unregisterMBean
protected void unregisterMBean(javax.management.ObjectName name)
createByAddressObjectName
protected javax.management.ObjectName createByAddressObjectName(java.lang.String type,
java.lang.String value)
throws java.io.IOException
- Throws:
java.io.IOException
createByClientIdObjectName
protected javax.management.ObjectName createByClientIdObjectName(java.lang.String value)
throws java.io.IOException
- Throws:
java.io.IOException
Copyright © 2005-2012. All Rights Reserved.