Class ProtonClientConnectionManager
java.lang.Object
org.apache.activemq.artemis.protocol.amqp.client.ProtonClientConnectionManager
- All Implemented Interfaces:
BaseConnectionLifeCycleListener<ProtonProtocolManager>, BufferHandler
public class ProtonClientConnectionManager
extends Object
implements BaseConnectionLifeCycleListener<ProtonProtocolManager>, BufferHandler
Manages the lifecycle of a proton client connection.
-
Constructor Summary
ConstructorsConstructorDescriptionProtonClientConnectionManager(AMQPClientConnectionFactory connectionFactory, Optional<EventHandler> eventHandler, ClientSASLFactory clientSASLFactory) -
Method Summary
Modifier and TypeMethodDescriptionvoidbufferReceived(Object connectionID, ActiveMQBuffer buffer) voidconnectionCreated(org.apache.activemq.artemis.core.server.ActiveMQComponent component, Connection connection, ProtonProtocolManager protocolManager) voidconnectionDestroyed(Object connectionID, boolean failed) voidconnectionException(Object connectionID, ActiveMQException me) voidconnectionReadyForWrites(Object connectionID, boolean ready) getConnection(Object connectionId) voidstop()Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface BufferHandler
endOfBatch
-
Constructor Details
-
ProtonClientConnectionManager
public ProtonClientConnectionManager(AMQPClientConnectionFactory connectionFactory, Optional<EventHandler> eventHandler, ClientSASLFactory clientSASLFactory)
-
-
Method Details
-
connectionCreated
public void connectionCreated(org.apache.activemq.artemis.core.server.ActiveMQComponent component, Connection connection, ProtonProtocolManager protocolManager) - Specified by:
connectionCreatedin interfaceBaseConnectionLifeCycleListener<ProtonProtocolManager>
-
connectionDestroyed
- Specified by:
connectionDestroyedin interfaceBaseConnectionLifeCycleListener<ProtonProtocolManager>
-
connectionException
- Specified by:
connectionExceptionin interfaceBaseConnectionLifeCycleListener<ProtonProtocolManager>
-
connectionReadyForWrites
- Specified by:
connectionReadyForWritesin interfaceBaseConnectionLifeCycleListener<ProtonProtocolManager>
-
stop
public void stop() -
bufferReceived
- Specified by:
bufferReceivedin interfaceBufferHandler
-
getConnection
-