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,
javax.management.ObjectName connectorName) |
Modifier and Type | Method and Description |
---|---|
protected javax.management.ObjectName |
createByAddressObjectName(java.lang.String type,
java.lang.String value) |
protected javax.management.ObjectName |
createByClientIdObjectName(java.lang.String value) |
Response |
processAddConnection(ConnectionInfo info) |
protected void |
registerMBean(javax.management.ObjectName name) |
void |
stopAsync() |
protected void |
unregisterMBean(javax.management.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, javax.management.ObjectName connectorName) throws java.io.IOException
java.io.IOException
public void stopAsync()
stopAsync
in class TransportConnection
public Response processAddConnection(ConnectionInfo info) throws java.lang.Exception
processAddConnection
in interface CommandVisitor
processAddConnection
in class TransportConnection
java.lang.Exception
protected void registerMBean(javax.management.ObjectName name)
protected void unregisterMBean(javax.management.ObjectName name)
protected javax.management.ObjectName createByAddressObjectName(java.lang.String type, java.lang.String value) throws java.io.IOException
java.io.IOException
protected javax.management.ObjectName createByClientIdObjectName(java.lang.String value) throws java.io.IOException
java.io.IOException
Copyright © 2005-2017. All Rights Reserved.