public class ProtonProtocolManager extends Object implements ProtocolManager<Interceptor>, NotificationListener
Constructor and Description |
---|
ProtonProtocolManager(ProtonProtocolManagerFactory factory,
ActiveMQServer server) |
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 remotingConnection) |
MessageConverter |
getConverter()
Gets the Message Converter towards ActiveMQ Artemis.
|
ProtocolManagerFactory<Interceptor> |
getFactory() |
String |
getPubSubPrefix() |
ActiveMQServer |
getServer() |
void |
handleBuffer(RemotingConnection connection,
ActiveMQBuffer buffer) |
void |
handshake(NettyServerConnection connection,
ActiveMQBuffer buffer) |
boolean |
isProtocol(byte[] array) |
void |
onNotification(Notification notification) |
void |
removeHandler(String name) |
void |
setPubSubPrefix(String pubSubPrefix) |
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.
|
public ProtonProtocolManager(ProtonProtocolManagerFactory factory, ActiveMQServer server)
public ActiveMQServer getServer()
public MessageConverter getConverter()
ProtocolManager
getConverter
in interface ProtocolManager<Interceptor>
public void onNotification(Notification notification)
onNotification
in interface NotificationListener
public ProtocolManagerFactory<Interceptor> getFactory()
getFactory
in interface ProtocolManager<Interceptor>
public void updateInterceptors(List<BaseInterceptor> incomingInterceptors, List<BaseInterceptor> outgoingInterceptors)
ProtocolManager
updateInterceptors
in interface ProtocolManager<Interceptor>
public boolean acceptsNoHandshake()
ProtocolManager
acceptsNoHandshake
in interface ProtocolManager<Interceptor>
public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed, Connection remotingConnection)
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 String getPubSubPrefix()
public void setPubSubPrefix(String pubSubPrefix)
Copyright © 2016 The Apache Software Foundation. All rights reserved.