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) |
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) |
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
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 doStop() throws java.lang.Exception
doStop
in class TransportConnection
java.lang.Exception
public void setConnectionId(java.lang.String connectionId) throws java.io.IOException
java.io.IOException
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-2012. All Rights Reserved.