Class CoreProtocolManager
java.lang.Object
org.apache.activemq.artemis.core.protocol.core.impl.CoreProtocolManager
- All Implemented Interfaces:
ProtocolManager<Interceptor,ActiveMQRoutingHandler>
public class CoreProtocolManager
extends Object
implements ProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionCoreProtocolManager(CoreProtocolManagerFactory factory, ActiveMQServer server, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors) -
Method Summary
Modifier and TypeMethodDescriptionbooleanIf this protocols accepts connectoins without an initial handshake.voidaddChannelHandlers(io.netty.channel.ChannelPipeline pipeline) createConnectionEntry(Acceptor acceptorUsed, Connection connection) voidhandleBuffer(RemotingConnection connection, ActiveMQBuffer buffer) voidhandshake(NettyServerConnection connection, ActiveMQBuffer buffer) booleanisProtocol(byte[] array) voidremoveHandler(String name) voidsetAnycastPrefix(String anycastPrefix) voidsetMulticastPrefix(String multicastPrefix) voidsetSecurityDomain(String securityDomain) toString()voidupdateInterceptors(List<BaseInterceptor> incoming, List<BaseInterceptor> outgoing) This method will receive all the interceptors on the system and you should filter them outA list of the IANA websocket subprotocol identifiers (https://www.iana.org/assignments/websocket/websocket.xhtml) supported by this protocol manager.
-
Field Details
-
server
-
-
Constructor Details
-
CoreProtocolManager
public CoreProtocolManager(CoreProtocolManagerFactory factory, ActiveMQServer server, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors)
-
-
Method Details
-
getFactory
- Specified by:
getFactoryin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
updateInterceptors
Description copied from interface:ProtocolManagerThis method will receive all the interceptors on the system and you should filter them out- Specified by:
updateInterceptorsin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
acceptsNoHandshake
public boolean acceptsNoHandshake()Description copied from interface:ProtocolManagerIf this protocols accepts connectoins without an initial handshake. If true this protocol will be the failback case no other connections are made. New designed protocols should always require a handshake. This is only useful for legacy protocols.- Specified by:
acceptsNoHandshakein interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
createConnectionEntry
- Specified by:
createConnectionEntryin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
removeHandler
- Specified by:
removeHandlerin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
handleBuffer
- Specified by:
handleBufferin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
addChannelHandlers
public void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline) - Specified by:
addChannelHandlersin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
isProtocol
public boolean isProtocol(byte[] array) - Specified by:
isProtocolin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
handshake
- Specified by:
handshakein interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
websocketSubprotocolIdentifiers
Description copied from interface:ProtocolManagerA list of the IANA websocket subprotocol identifiers (https://www.iana.org/assignments/websocket/websocket.xhtml) supported by this protocol manager. These are used during the websocket subprotocol handshake.- Specified by:
websocketSubprotocolIdentifiersin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler> - Returns:
- A list of subprotocol ids
-
setAnycastPrefix
- Specified by:
setAnycastPrefixin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
setMulticastPrefix
- Specified by:
setMulticastPrefixin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
getPrefixes
- Specified by:
getPrefixesin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
setSecurityDomain
- Specified by:
setSecurityDomainin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
getSecurityDomain
- Specified by:
getSecurityDomainin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
getRoutingHandler
- Specified by:
getRoutingHandlerin interfaceProtocolManager<Interceptor,ActiveMQRoutingHandler>
-
toString
-