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>

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)
MessageConverter	getConverter() no need to implement this now
ProtocolManagerFactory<Interceptor>	getFactory()
void	handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
void	handshake(NettyServerConnection connection, ActiveMQBuffer buffer)
boolean	isProtocol(byte[] array)
void	removeHandler(String name)
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 *

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<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 conenctions are made. New designed protocols should always require a handshake. This is only useful for legacy protocols.

Specified by:

acceptsNoHandshake in interface ProtocolManager<Interceptor>

getConverter

public MessageConverter getConverter()

no need to implement this now

Specified by:

getConverter in interface ProtocolManager<Interceptor>

Returns:

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>

toString

public String toString()

Overrides:

toString in class Object