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

Class CoreProtocolManager

java.lang.Object

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

All Implemented Interfaces:

ProtocolManager<Interceptor>

public class CoreProtocolManager
extends Object
implements ProtocolManager<Interceptor>

Field Summary

Fields

Modifier and Type	Field and Description
protected ActiveMQServer	server

Constructor Summary

Constructors

Constructor and Description
CoreProtocolManager(CoreProtocolManagerFactory factory, ActiveMQServer server, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors)

Method Summary

Modifier and Type	Method and Description
boolean	acceptsNoHandshake() If this protocols accepts connectoins without an initial handshake.
void	addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)
ConnectionEntry	createConnectionEntry(Acceptor acceptorUsed, Connection connection)
ProtocolManagerFactory<Interceptor>	getFactory()
Map<SimpleString,RoutingType>	getPrefixes()
String	getSecurityDomain()
void	handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
void	handshake(NettyServerConnection connection, ActiveMQBuffer buffer)
boolean	isProtocol(byte[] array)
void	removeHandler(String name)
void	setAnycastPrefix(String anycastPrefix)
void	setMulticastPrefix(String multicastPrefix)
void	setSecurityDomain(String securityDomain)
String	toString()
void	updateInterceptors(List<BaseInterceptor> incoming, List<BaseInterceptor> outgoing) This method will receive all the interceptors on the system and you should filter them out *
List<String>	websocketSubprotocolIdentifiers() A list of the IANA websocket subprotocol identifiers (https://www.iana.org/assignments/websocket/websocket.xhtml) supported by this protocol manager.

Methods inherited from class java.lang.Object

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

Field Detail

server

protected final ActiveMQServer server

Constructor Detail

CoreProtocolManager

public CoreProtocolManager(CoreProtocolManagerFactory factory,
                           ActiveMQServer server,
                           List<Interceptor> incomingInterceptors,
                           List<Interceptor> outgoingInterceptors)

Method Detail

getFactory

public ProtocolManagerFactory<Interceptor> getFactory()

Specified by:

getFactory in interface ProtocolManager<Interceptor>

updateInterceptors

public void updateInterceptors(List<BaseInterceptor> incoming,
                               List<BaseInterceptor> outgoing)

Description copied from interface: ProtocolManager

This method will receive all the interceptors on the system and you should filter them out *

Specified by:

updateInterceptors in interface ProtocolManager<Interceptor>

acceptsNoHandshake

public boolean acceptsNoHandshake()

Description copied from interface: ProtocolManager

If this protocols accepts connectoins without an initial handshake. If true this protocol will be the failback case no other connections are made. New designed protocols should always require a handshake. This is only useful for legacy protocols.

Specified by:

acceptsNoHandshake in interface ProtocolManager<Interceptor>

createConnectionEntry

public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
                                             Connection connection)

Specified by:

createConnectionEntry in interface ProtocolManager<Interceptor>

removeHandler

public void removeHandler(String name)

Specified by:

removeHandler in interface ProtocolManager<Interceptor>

handleBuffer

public void handleBuffer(RemotingConnection connection,
                         ActiveMQBuffer buffer)

Specified by:

handleBuffer in interface ProtocolManager<Interceptor>

addChannelHandlers

public void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)

Specified by:

addChannelHandlers in interface ProtocolManager<Interceptor>

isProtocol

public boolean isProtocol(byte[] array)

Specified by:

isProtocol in interface ProtocolManager<Interceptor>

handshake

public void handshake(NettyServerConnection connection,
                      ActiveMQBuffer buffer)

Specified by:

handshake in interface ProtocolManager<Interceptor>

websocketSubprotocolIdentifiers

public List<String> websocketSubprotocolIdentifiers()

Description copied from interface: ProtocolManager

A list of the IANA websocket subprotocol identifiers (https://www.iana.org/assignments/websocket/websocket.xhtml) supported by this protocol manager. These are used during the websocket subprotocol handshake.

Specified by:

websocketSubprotocolIdentifiers in interface ProtocolManager<Interceptor>

Returns:

A list of subprotocol ids

setAnycastPrefix

public void setAnycastPrefix(String anycastPrefix)

Specified by:

setAnycastPrefix in interface ProtocolManager<Interceptor>

setMulticastPrefix

public void setMulticastPrefix(String multicastPrefix)

Specified by:

setMulticastPrefix in interface ProtocolManager<Interceptor>

getPrefixes

public Map<SimpleString,RoutingType> getPrefixes()

Specified by:

getPrefixes in interface ProtocolManager<Interceptor>

setSecurityDomain

public void setSecurityDomain(String securityDomain)

Specified by:

setSecurityDomain in interface ProtocolManager<Interceptor>

getSecurityDomain

public String getSecurityDomain()

Specified by:

getSecurityDomain in interface ProtocolManager<Interceptor>

toString

public String toString()

Overrides:

toString in class Object