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>

public class ProtonProtocolManagerFactory
extends AbstractProtocolManagerFactory<AmqpInterceptor>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AMQP_PROTOCOL_NAME

Constructor Summary

Constructors

Constructor	Description
ProtonProtocolManagerFactory()

Method Summary

Modifier and Type	Method	Description
ProtocolManager	createProtocolManager(org.apache.activemq.artemis.core.server.ActiveMQServer server, Map<String,Object> parameters, List<BaseInterceptor> incomingInterceptors, List<BaseInterceptor> outgoingInterceptors)
List<AmqpInterceptor>	filterInterceptors(List<BaseInterceptor> interceptors)
String	getModuleName()
org.apache.activemq.artemis.core.persistence.Persister<Message>[]	getPersister()
String[]	getProtocols()
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.
void	updateProtocolServices(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

Methods inherited from class Object

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

Field Details

AMQP_PROTOCOL_NAME

public static final String AMQP_PROTOCOL_NAME

See Also:

• Constant Field Values

Constructor Details

ProtonProtocolManagerFactory

public ProtonProtocolManagerFactory()

Method Details

getPersister

public org.apache.activemq.artemis.core.persistence.Persister<Message>[] 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

public List<AmqpInterceptor> filterInterceptors(List<BaseInterceptor> interceptors)

getProtocols

public String[] getProtocols()

getModuleName

public String 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:

loadProtocolServices in interface ProtocolManagerFactory<AmqpInterceptor>

Overrides:

loadProtocolServices in class AbstractProtocolManagerFactory<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:

updateProtocolServices in interface ProtocolManagerFactory<AmqpInterceptor>

Overrides:

updateProtocolServices in class AbstractProtocolManagerFactory<AmqpInterceptor>

Throws:

Exception