org.apache.activemq.broker.jmx
Class ManagedTransportConnection

java.lang.Object
  extended by org.apache.activemq.broker.TransportConnection
      extended by 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
ManagedTransportConnection(TransportConnector connector, Transport transport, Broker broker, TaskRunnerFactory factory, ManagementContext context, javax.management.ObjectName connectorName)
           
 
Method Summary
protected  javax.management.ObjectName createByAddressObjectName(java.lang.String type, java.lang.String value)
           
protected  javax.management.ObjectName createByClientIdObjectName(java.lang.String value)
           
 void doStop()
           
 Response processAddConnection(ConnectionInfo info)
           
protected  void registerMBean(javax.management.ObjectName name)
           
 void setConnectionId(java.lang.String connectionId)
          Sets the connection ID of this connection.
protected  void unregisterMBean(javax.management.ObjectName name)
           
 
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
 

Constructor Detail

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
Method Detail

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.