public interface ProtocolManager<P extends BaseInterceptor>
RemotingServiceImpl.loadProtocolManagerFactories(Iterable)
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<P> |
getFactory() |
Map<SimpleString,RoutingType> |
getPrefixes() |
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 |
updateInterceptors(List<BaseInterceptor> incomingInterceptors,
List<BaseInterceptor> outgoingInterceptors)
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.
|
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)
boolean acceptsNoHandshake()
void handshake(NettyServerConnection connection, ActiveMQBuffer buffer)
List<String> websocketSubprotocolIdentifiers()
void setAnycastPrefix(String anycastPrefix)
void setMulticastPrefix(String multicastPrefix)
Map<SimpleString,RoutingType> getPrefixes()
Copyright © 2018 JBoss by Red Hat. All rights reserved.