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

Constructors

Constructor	Description
ProtonClientConnectionManager(AMQPClientConnectionFactory connectionFactory, Optional<EventHandler> eventHandler, ClientSASLFactory clientSASLFactory)

Method Summary

Modifier and Type	Method	Description
void	bufferReceived(Object connectionID, ActiveMQBuffer buffer)
void	connectionCreated(org.apache.activemq.artemis.core.server.ActiveMQComponent component, Connection connection, ProtonProtocolManager protocolManager)
void	connectionDestroyed(Object connectionID, boolean failed)
void	connectionException(Object connectionID, ActiveMQException me)
void	connectionReadyForWrites(Object connectionID, boolean ready)
RemotingConnection	getConnection(Object connectionId)
void	stop()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods 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:

connectionCreated in interface BaseConnectionLifeCycleListener<ProtonProtocolManager>

connectionDestroyed

public void connectionDestroyed(Object connectionID,
 boolean failed)

Specified by:

connectionDestroyed in interface BaseConnectionLifeCycleListener<ProtonProtocolManager>

connectionException

public void connectionException(Object connectionID,
 ActiveMQException me)

Specified by:

connectionException in interface BaseConnectionLifeCycleListener<ProtonProtocolManager>

connectionReadyForWrites

public void connectionReadyForWrites(Object connectionID,
 boolean ready)

Specified by:

connectionReadyForWrites in interface BaseConnectionLifeCycleListener<ProtonProtocolManager>

stop

public void stop()

bufferReceived

public void bufferReceived(Object connectionID,
 ActiveMQBuffer buffer)

Specified by:

bufferReceived in interface BufferHandler

getConnection

public RemotingConnection getConnection(Object connectionId)