Class ProtonProtocolManagerFactory
java.lang.Object
org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManagerFactory<AmqpInterceptor>
org.apache.activemq.artemis.protocol.amqp.broker.ProtonProtocolManagerFactory
- All Implemented Interfaces:
ProtocolManagerFactory<AmqpInterceptor>
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncreateProtocolManager(org.apache.activemq.artemis.core.server.ActiveMQServer server, Map<String, Object> parameters, List<BaseInterceptor> incomingInterceptors, List<BaseInterceptor> outgoingInterceptors) filterInterceptors(List<BaseInterceptor> interceptors) org.apache.activemq.artemis.core.persistence.Persister<Message>[]String[]voidloadProtocolServices(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) AMQP integration with the broker on this case needs to be soft as the broker may choose to not load the AMQP Protocol module.voidupdateProtocolServices(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) Check if broker configuration of AMQP broker connections or other broker configuration related to protocol services has been updated and update the protocol services accordingly.Methods inherited from class AbstractProtocolManagerFactory
internalFilterInterceptors
-
Field Details
-
AMQP_PROTOCOL_NAME
- See Also:
-
-
Constructor Details
-
ProtonProtocolManagerFactory
public ProtonProtocolManagerFactory()
-
-
Method Details
-
getPersister
-
createProtocolManager
public ProtocolManager createProtocolManager(org.apache.activemq.artemis.core.server.ActiveMQServer server, Map<String, Object> parameters, List<BaseInterceptor> incomingInterceptors, List<BaseInterceptor> outgoingInterceptors) throws Exception- Throws:
Exception
-
filterInterceptors
-
getProtocols
-
getModuleName
-
loadProtocolServices
public void loadProtocolServices(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) AMQP integration with the broker on this case needs to be soft as the broker may choose to not load the AMQP Protocol module.- Specified by:
loadProtocolServicesin interfaceProtocolManagerFactory<AmqpInterceptor>- Overrides:
loadProtocolServicesin classAbstractProtocolManagerFactory<AmqpInterceptor>
-
updateProtocolServices
public void updateProtocolServices(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) throws Exception Check if broker configuration of AMQP broker connections or other broker configuration related to protocol services has been updated and update the protocol services accordingly.- Specified by:
updateProtocolServicesin interfaceProtocolManagerFactory<AmqpInterceptor>- Overrides:
updateProtocolServicesin classAbstractProtocolManagerFactory<AmqpInterceptor>- Throws:
Exception
-