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 $
Fields inherited from class org.apache.activemq.broker.TransportConnection |
asyncException, broker, brokerConnectionStates, brokerInfo, connector, dispatchQueue, dispatchStopped, disposed, localConnectionStates, taskRunner, transportException |
Methods inherited from class org.apache.activemq.broker.TransportConnection |
dispatch, dispatchAsync, dispatchSync, disposeTransport, doMark, getConnectionId, getConnector, getDispatchQueueSize, getMessageAuthorizationPolicy, getRemoteAddress, getStatistics, isActive, isBlocked, isBlockedCandidate, isConnected, isManageable, isMarkedBlockedCandidate, isMarkedCandidate, isPendingStop, isSlow, isStarting, iterate, lookupConnectionState, lookupConnectionState, lookupConnectionState, lookupConnectionState, processAddConsumer, processAddDestination, processAddProducer, processAddSession, processBeginTransaction, processBrokerInfo, processCommitTransactionOnePhase, processCommitTransactionTwoPhase, processDispatch, processEndTransaction, processFlush, processForgetTransaction, processKeepAlive, processMessage, processMessageAck, processMessageDispatchNotification, processMessagePull, processPrepareTransaction, processRecoverTransactions, processRemoveConnection, processRemoveConsumer, processRemoveDestination, processRemoveProducer, processRemoveSession, processRemoveSubscription, processRollbackTransaction, processShutdown, processWireFormat, service, serviceException, serviceExceptionAsync, serviceTransportException, setActive, setBlocked, setBlockedCandidate, setConnected, setMarkedCandidate, setMessageAuthorizationPolicy, setPendingStop, setSlow, setStarting, start |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ManagedTransportConnection
public ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
javax.management.MBeanServer server,
javax.management.ObjectName connectorName)
throws java.io.IOException
- Throws:
java.io.IOException
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
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 © 2009 Apache Software Foundation. All Rights Reserved.