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, TaskRunnerFactory stopFactory, ManagementContext context, ObjectName connectorName)
           
 
Method Summary
protected  ObjectName createObjectName(String type, String value)
           
 Response processAddConnection(ConnectionInfo info)
           
protected  void registerMBean(ObjectName name)
           
 void stopAsync()
           
protected  void unregisterMBean(ObjectName name)
           
 
Methods inherited from class org.apache.activemq.broker.TransportConnection
delayedStop, dispatch, dispatchAsync, dispatchSync, doMark, doStop, getConnectionId, getConnector, getDispatchQueueSize, getDuplexNetworkConnectorId, getMessageAuthorizationPolicy, getProtocolVersion, getRemoteAddress, getStatistics, getStopped, isActive, isBlocked, isBlockedCandidate, isConnected, isFaultTolerantConnection, isManageable, isMarkedBlockedCandidate, isMarkedCandidate, isNetworkConnection, isPendingStop, isSlow, isStarting, isStopping, 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, 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,
                                  TaskRunnerFactory stopFactory,
                                  ManagementContext context,
                                  ObjectName connectorName)
                           throws IOException
Throws:
IOException
Method Detail

stopAsync

public void stopAsync()
Overrides:
stopAsync in class TransportConnection

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)

createObjectName

protected ObjectName createObjectName(String type,
                                      String value)
                               throws IOException
Throws:
IOException


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.