Interface ProtocolManagerFactory<P extends BaseInterceptor>
- All Known Implementing Classes:
AbstractProtocolManagerFactory
public interface ProtocolManagerFactory<P extends BaseInterceptor>
-
Method Summary
Modifier and TypeMethodDescriptioncreateProtocolManager
(org.apache.activemq.artemis.core.server.ActiveMQServer server, Map<String, Object> parameters, List<BaseInterceptor> incomingInterceptors, List<BaseInterceptor> outgoingInterceptors) When you create the ProtocolManager, you should filter out any interceptors that won't belong to this Protocol.filterInterceptors
(List<BaseInterceptor> interceptors) This should get the entire list and only return the ones this factory can deal with *default org.apache.activemq.artemis.core.persistence.Persister<Message>[]
String[]
void
loadProtocolServices
(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) void
updateProtocolServices
(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) Provides an entry point for the server to trigger the protocol manager factory to update its protocol services based on updates to server configuration.
-
Method Details
-
getPersister
-
createProtocolManager
ProtocolManager createProtocolManager(org.apache.activemq.artemis.core.server.ActiveMQServer server, Map<String, Object> parameters, List<BaseInterceptor> incomingInterceptors, List<BaseInterceptor> outgoingInterceptors) throws ExceptionWhen you create the ProtocolManager, you should filter out any interceptors that won't belong to this Protocol. For example don't send any core InterceptorsInterceptor
to Stomp * * *- Parameters:
server
-incomingInterceptors
-outgoingInterceptors
-- Returns:
- Throws:
Exception
-
filterInterceptors
This should get the entire list and only return the ones this factory can deal with *- Parameters:
interceptors
-- Returns:
-
getProtocols
String[] getProtocols() -
getModuleName
String getModuleName() -
loadProtocolServices
void loadProtocolServices(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) -
updateProtocolServices
void updateProtocolServices(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) throws Exception Provides an entry point for the server to trigger the protocol manager factory to update its protocol services based on updates to server configuration.- Parameters:
server
- The service instance that has triggered this updateservices
- The protocol services that were previously registered (mutable).- Throws:
Exception
- can throw an exception if an error occurs while updating or adding protocol services from configuration updates.
-