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

Version:
$Revision: 1.1 $

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, ObjectName connectorName)
           
 
Method Summary
protected  ObjectName createByAddressObjectName(String type, String value)
           
protected  ObjectName createByClientIdObjectName(String value)
           
 void doStop()
           
 Response processAddConnection(ConnectionInfo info)
           
protected  void registerMBean(ObjectName name)
           
 void setConnectionId(String connectionId)
          Sets the connection ID of this connection.
protected  void unregisterMBean(ObjectName name)
           
 
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
 
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,
                                  ObjectName connectorName)
                           throws IOException
Throws:
IOException
Method Detail

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.