org.apache.activemq.artemis.core.protocol.proton

Class ProtonProtocolManager

java.lang.Object

org.apache.activemq.artemis.core.protocol.proton.ProtonProtocolManager

All Implemented Interfaces:

NotificationListener, ProtocolManager<Interceptor>

public class ProtonProtocolManager
extends Object
implements ProtocolManager<Interceptor>, NotificationListener

A proton protocol manager, basically reads the Proton Input and maps proton resources to ActiveMQ Artemis resources

Constructor Summary

Constructors

Constructor and Description
ProtonProtocolManager(ProtonProtocolManagerFactory factory, ActiveMQServer server)

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 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProtonProtocolManager

public ProtonProtocolManager(ProtonProtocolManagerFactory factory,
                             ActiveMQServer server)

Method Detail

getServer

public ActiveMQServer getServer()

getConverter

public MessageConverter getConverter()

Description copied from interface: ProtocolManager

Gets the Message Converter towards ActiveMQ Artemis. Notice this being null means no need to convert

Specified by:

getConverter in interface ProtocolManager<Interceptor>

Returns:

onNotification

public void onNotification(Notification notification)

Specified by:

onNotification in interface NotificationListener

getFactory

public ProtocolManagerFactory<Interceptor> getFactory()

Specified by:

getFactory in interface ProtocolManager<Interceptor>

updateInterceptors

public void updateInterceptors(List<BaseInterceptor> incomingInterceptors,
                               List<BaseInterceptor> outgoingInterceptors)

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>

createConnectionEntry

public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
                                             Connection remotingConnection)

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>

websocketSubprotocolIdentifiers

public List<String> websocketSubprotocolIdentifiers()

Description copied from interface: ProtocolManager

A list of the IANA websocket subprotocol identifiers supported by this protocol manager. These are used during the websocket subprotocol handshake.

Specified by:

websocketSubprotocolIdentifiers in interface ProtocolManager<Interceptor>

Returns:

A list of subprotocol ids

getPubSubPrefix

public String getPubSubPrefix()

setPubSubPrefix

public void setPubSubPrefix(String pubSubPrefix)