public class ManagedTransportConnection extends TransportConnection
broker, brokerConnectionStates, brokerInfo, connector, dispatchQueue, dispatchStopped, taskRunner, transportException
Constructor and Description |
---|
ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
ManagementContext context,
ObjectName connectorName) |
Modifier and Type | Method and Description |
---|---|
protected ObjectName |
createByAddressObjectName(String type,
String value) |
protected ObjectName |
createByClientIdObjectName(String value) |
Response |
processAddConnection(ConnectionInfo info) |
protected void |
registerMBean(ObjectName name) |
void |
stopAsync() |
protected void |
unregisterMBean(ObjectName name) |
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
public ManagedTransportConnection(TransportConnector connector, Transport transport, Broker broker, TaskRunnerFactory factory, ManagementContext context, ObjectName connectorName) throws IOException
IOException
public void stopAsync()
stopAsync
in class TransportConnection
public Response processAddConnection(ConnectionInfo info) throws Exception
processAddConnection
in interface CommandVisitor
processAddConnection
in class TransportConnection
Exception
protected void registerMBean(ObjectName name)
protected void unregisterMBean(ObjectName name)
protected ObjectName createByAddressObjectName(String type, String value) throws IOException
IOException
protected ObjectName createByClientIdObjectName(String value) throws IOException
IOException
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.