public class CoreProtocolManager extends Object implements ProtocolManager<Interceptor>
Modifier and Type | Field and Description |
---|---|
protected ActiveMQServer |
server |
Constructor and Description |
---|
CoreProtocolManager(CoreProtocolManagerFactory factory,
ActiveMQServer server,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
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() |
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) |
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 supported by this protocol manager.
|
protected final ActiveMQServer server
public CoreProtocolManager(CoreProtocolManagerFactory factory, ActiveMQServer server, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors)
public ProtocolManagerFactory<Interceptor> getFactory()
getFactory
in interface ProtocolManager<Interceptor>
public void updateInterceptors(List<BaseInterceptor> incoming, List<BaseInterceptor> outgoing)
ProtocolManager
updateInterceptors
in interface ProtocolManager<Interceptor>
public boolean acceptsNoHandshake()
ProtocolManager
acceptsNoHandshake
in interface ProtocolManager<Interceptor>
public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed, Connection connection)
createConnectionEntry
in interface ProtocolManager<Interceptor>
public void removeHandler(String name)
removeHandler
in interface ProtocolManager<Interceptor>
public void handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
handleBuffer
in interface ProtocolManager<Interceptor>
public void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)
addChannelHandlers
in interface ProtocolManager<Interceptor>
public boolean isProtocol(byte[] array)
isProtocol
in interface ProtocolManager<Interceptor>
public void handshake(NettyServerConnection connection, ActiveMQBuffer buffer)
handshake
in interface ProtocolManager<Interceptor>
public List<String> websocketSubprotocolIdentifiers()
ProtocolManager
websocketSubprotocolIdentifiers
in interface ProtocolManager<Interceptor>
public void setAnycastPrefix(String anycastPrefix)
setAnycastPrefix
in interface ProtocolManager<Interceptor>
public void setMulticastPrefix(String multicastPrefix)
setMulticastPrefix
in interface ProtocolManager<Interceptor>
public Map<SimpleString,RoutingType> getPrefixes()
getPrefixes
in interface ProtocolManager<Interceptor>
Copyright © 2019 JBoss by Red Hat. All rights reserved.