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<org.apache.activemq.artemis.api.core.Interceptor>

public class CoreProtocolManager
extends Object
implements ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

Constructor Summary

Constructors

Constructor and Description
CoreProtocolManager(CoreProtocolManagerFactory factory, ActiveMQServer server, List<org.apache.activemq.artemis.api.core.Interceptor> incomingInterceptors, List<org.apache.activemq.artemis.api.core.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)
org.apache.activemq.artemis.spi.core.protocol.ConnectionEntry	createConnectionEntry(Acceptor acceptorUsed, org.apache.activemq.artemis.spi.core.remoting.Connection connection)
MessageConverter	getConverter() no need to implement this now
ProtocolManagerFactory<org.apache.activemq.artemis.api.core.Interceptor>	getFactory()
void	handleBuffer(org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection, org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
void	handshake(NettyServerConnection connection, org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
boolean	isProtocol(byte[] array)
void	removeHandler(String name)
String	toString()
void	updateInterceptors(List<org.apache.activemq.artemis.api.core.BaseInterceptor> incoming, List<org.apache.activemq.artemis.api.core.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 supported by this protocol manager.

Methods inherited from class java.lang.Object

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

Constructor Detail

CoreProtocolManager

public CoreProtocolManager(CoreProtocolManagerFactory factory,
                           ActiveMQServer server,
                           List<org.apache.activemq.artemis.api.core.Interceptor> incomingInterceptors,
                           List<org.apache.activemq.artemis.api.core.Interceptor> outgoingInterceptors)

Method Detail

getFactory

public ProtocolManagerFactory<org.apache.activemq.artemis.api.core.Interceptor> getFactory()

Specified by:

getFactory in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

updateInterceptors

public void updateInterceptors(List<org.apache.activemq.artemis.api.core.BaseInterceptor> incoming,
                               List<org.apache.activemq.artemis.api.core.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<org.apache.activemq.artemis.api.core.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<org.apache.activemq.artemis.api.core.Interceptor>

getConverter

public MessageConverter getConverter()

no need to implement this now

Specified by:

getConverter in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

Returns:

createConnectionEntry

public org.apache.activemq.artemis.spi.core.protocol.ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
                                                                                           org.apache.activemq.artemis.spi.core.remoting.Connection connection)

Specified by:

createConnectionEntry in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

removeHandler

public void removeHandler(String name)

Specified by:

removeHandler in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

handleBuffer

public void handleBuffer(org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection,
                         org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

Specified by:

handleBuffer in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

addChannelHandlers

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

Specified by:

addChannelHandlers in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

isProtocol

public boolean isProtocol(byte[] array)

Specified by:

isProtocol in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

handshake

public void handshake(NettyServerConnection connection,
                      org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

Specified by:

handshake in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

websocketSubprotocolIdentifiers

public List<String> websocketSubprotocolIdentifiers()

Description copied from interface: ProtocolManager

A list of the IANA websocket subprotocol identifiers supported by this protocol manager. These are used during the websocket subprotocol handshake.

Specified by:

websocketSubprotocolIdentifiers in interface ProtocolManager<org.apache.activemq.artemis.api.core.Interceptor>

Returns:

A list of subprotocol ids

toString

public String toString()

Overrides:

toString in class Object