org.apache.activemq.artemis.spi.core.protocol

Class AbstractProtocolManager<P,I extends BaseInterceptor<P>,C extends RemotingConnection,R extends org.apache.activemq.artemis.core.server.balancing.RedirectHandler>

java.lang.Object

org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManager<P,I,C,R>

All Implemented Interfaces:

ProtocolManager<I,R>

public abstract class AbstractProtocolManager<P,I extends BaseInterceptor<P>,C extends RemotingConnection,R extends org.apache.activemq.artemis.core.server.balancing.RedirectHandler>
extends Object
implements ProtocolManager<I,R>

Constructor Summary

Constructors

Constructor and Description
AbstractProtocolManager()

Method Summary

Modifier and Type	Method and Description
Map<SimpleString,RoutingType>	getPrefixes()
String	getSecurityDomain()
protected String	invokeInterceptors(List<I> interceptors, P message, C connection)
void	setAnycastPrefix(String anycastPrefix)
void	setMulticastPrefix(String multicastPrefix)
void	setSecurityDomain(String securityDomain)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.spi.core.protocol.ProtocolManager

acceptsNoHandshake, addChannelHandlers, createConnectionEntry, getFactory, getRedirectHandler, handleBuffer, handshake, isProtocol, removeHandler, updateInterceptors, websocketSubprotocolIdentifiers

Constructor Detail

AbstractProtocolManager

public AbstractProtocolManager()

Method Detail

invokeInterceptors

protected String invokeInterceptors(List<I> interceptors,
                                    P message,
                                    C connection)

setAnycastPrefix

public void setAnycastPrefix(String anycastPrefix)

Specified by:

setAnycastPrefix in interface ProtocolManager<I extends BaseInterceptor<P>,R extends org.apache.activemq.artemis.core.server.balancing.RedirectHandler>

setMulticastPrefix

public void setMulticastPrefix(String multicastPrefix)

Specified by:

setMulticastPrefix in interface ProtocolManager<I extends BaseInterceptor<P>,R extends org.apache.activemq.artemis.core.server.balancing.RedirectHandler>

getPrefixes

public Map<SimpleString,RoutingType> getPrefixes()

Specified by:

getPrefixes in interface ProtocolManager<I extends BaseInterceptor<P>,R extends org.apache.activemq.artemis.core.server.balancing.RedirectHandler>

getSecurityDomain

public String getSecurityDomain()

Specified by:

getSecurityDomain in interface ProtocolManager<I extends BaseInterceptor<P>,R extends org.apache.activemq.artemis.core.server.balancing.RedirectHandler>

setSecurityDomain

public void setSecurityDomain(String securityDomain)

Specified by:

setSecurityDomain in interface ProtocolManager<I extends BaseInterceptor<P>,R extends org.apache.activemq.artemis.core.server.balancing.RedirectHandler>