public interface ProtocolManager<P extends BaseInterceptor>
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()
Gets the Message Converter towards ActiveMQ Artemis.
|
ProtocolManagerFactory<P> |
getFactory() |
void |
handleBuffer(RemotingConnection connection,
ActiveMQBuffer buffer) |
void |
handshake(NettyServerConnection connection,
ActiveMQBuffer buffer) |
boolean |
isProtocol(byte[] array) |
void |
removeHandler(String name) |
void |
updateInterceptors(List<BaseInterceptor> incomingInterceptors,
List<BaseInterceptor> outgoingInterceptors)
This method will receive all the interceptors on the system and you should filter them out *
|
ProtocolManagerFactory<P> getFactory()
void updateInterceptors(List<BaseInterceptor> incomingInterceptors, List<BaseInterceptor> outgoingInterceptors)
incomingInterceptors
- outgoingInterceptors
- ConnectionEntry createConnectionEntry(Acceptor acceptorUsed, Connection connection)
void removeHandler(String name)
void handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)
boolean isProtocol(byte[] array)
MessageConverter getConverter()
boolean acceptsNoHandshake()
void handshake(NettyServerConnection connection, ActiveMQBuffer buffer)
Copyright © 2016 JBoss by Red Hat. All rights reserved.