org.apache.activemq.artemis.core.protocol.core.impl

Class CoreProtocolManagerFactory

java.lang.Object

org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManagerFactory<org.apache.activemq.artemis.api.core.Interceptor>

org.apache.activemq.artemis.core.protocol.core.impl.CoreProtocolManagerFactory

All Implemented Interfaces:

ProtocolManagerFactory<org.apache.activemq.artemis.api.core.Interceptor>

public class CoreProtocolManagerFactory
extends AbstractProtocolManagerFactory<org.apache.activemq.artemis.api.core.Interceptor>

Constructor Summary

Constructors

Constructor and Description
CoreProtocolManagerFactory()

Method Summary

Modifier and Type	Method and Description
ProtocolManager	createProtocolManager(ActiveMQServer server, Map<String,Object> parameters, List<org.apache.activemq.artemis.api.core.BaseInterceptor> incomingInterceptors, List<org.apache.activemq.artemis.api.core.BaseInterceptor> outgoingInterceptors) When you create the ProtocolManager, you should filter out any interceptors that won't belong to this Protocol.
List<org.apache.activemq.artemis.api.core.Interceptor>	filterInterceptors(List<org.apache.activemq.artemis.api.core.BaseInterceptor> interceptors) This should get the entire list and only return the ones this factory can deal with *
String	getModuleName()
String[]	getProtocols()

Methods inherited from class org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManagerFactory

internalFilterInterceptors

Methods inherited from class java.lang.Object

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

Constructor Detail

CoreProtocolManagerFactory

public CoreProtocolManagerFactory()

Method Detail

createProtocolManager

public ProtocolManager createProtocolManager(ActiveMQServer server,
                                             Map<String,Object> parameters,
                                             List<org.apache.activemq.artemis.api.core.BaseInterceptor> incomingInterceptors,
                                             List<org.apache.activemq.artemis.api.core.BaseInterceptor> outgoingInterceptors)
                                      throws Exception

When you create the ProtocolManager, you should filter out any interceptors that won't belong to this Protocol. For example don't send any core Interceptors Interceptor to Stomp * * * *

Parameters:

server -

incomingInterceptors -

outgoingInterceptors -

Returns:

Throws:

Exception

filterInterceptors

public List<org.apache.activemq.artemis.api.core.Interceptor> filterInterceptors(List<org.apache.activemq.artemis.api.core.BaseInterceptor> interceptors)

Description copied from interface: ProtocolManagerFactory

This should get the entire list and only return the ones this factory can deal with *

Returns:

getProtocols

public String[] getProtocols()

getModuleName

public String getModuleName()