Class AMQPBrokerConnectionManager
java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.AMQPBrokerConnectionManager
- All Implemented Interfaces:
org.apache.activemq.artemis.core.server.ActiveMQComponent, BaseConnectionLifeCycleListener<ClientProtocolManager>, ClientConnectionLifeCycleListener
public class AMQPBrokerConnectionManager
extends Object
implements org.apache.activemq.artemis.core.server.ActiveMQComponent, ClientConnectionLifeCycleListener
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classThe Client Protocol Manager is used for Core Clients. -
Constructor Summary
ConstructorsConstructorDescriptionAMQPBrokerConnectionManager(ProtonProtocolManagerFactory factory, List<AMQPBrokerConnectConfiguration> amqpConnectionsConfig, org.apache.activemq.artemis.core.server.ActiveMQServer server) -
Method Summary
Modifier and TypeMethodDescriptionvoidconnected(org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnection nettyConnection, AMQPBrokerConnection bridgeConnection) voidconnectionCreated(org.apache.activemq.artemis.core.server.ActiveMQComponent component, Connection connection, ClientProtocolManager protocol) voidconnectionDestroyed(Object connectionID, boolean failed) voidconnectionException(Object connectionID, ActiveMQException me) voidconnectionReadyForWrites(Object connectionID, boolean ready) intReturns the number of configured broker connection configurations.booleanvoidstart()voidstop()voidupdateConfiguration(List<AMQPBrokerConnectConfiguration> configurations) Updates the configuration of any / all broker connections in the broker connection manager based on updated broker configuration.Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent
asyncStop
-
Constructor Details
-
AMQPBrokerConnectionManager
public AMQPBrokerConnectionManager(ProtonProtocolManagerFactory factory, List<AMQPBrokerConnectConfiguration> amqpConnectionsConfig, org.apache.activemq.artemis.core.server.ActiveMQServer server)
-
-
Method Details
-
start
-
getConfiguredConnectionsCount
public int getConfiguredConnectionsCount()Returns the number of configured broker connection configurations.- Returns:
- the number of configured broker connection configurations
-
updateConfiguration
public void updateConfiguration(List<AMQPBrokerConnectConfiguration> configurations) throws Exception Updates the configuration of any / all broker connections in the broker connection manager based on updated broker configuration.- Parameters:
configurations- A list of broker connection configurations after a broker configuration update.- Throws:
Exception
-
connected
public void connected(org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnection nettyConnection, AMQPBrokerConnection bridgeConnection) -
stop
-
isStarted
public boolean isStarted()- Specified by:
isStartedin interfaceorg.apache.activemq.artemis.core.server.ActiveMQComponent
-
connectionCreated
public void connectionCreated(org.apache.activemq.artemis.core.server.ActiveMQComponent component, Connection connection, ClientProtocolManager protocol) - Specified by:
connectionCreatedin interfaceBaseConnectionLifeCycleListener<ClientProtocolManager>
-
connectionDestroyed
- Specified by:
connectionDestroyedin interfaceBaseConnectionLifeCycleListener<ClientProtocolManager>
-
connectionException
- Specified by:
connectionExceptionin interfaceBaseConnectionLifeCycleListener<ClientProtocolManager>
-
connectionReadyForWrites
- Specified by:
connectionReadyForWritesin interfaceBaseConnectionLifeCycleListener<ClientProtocolManager>
-