Package org.apache.activemq.artemis.spi.core.protocol

Interface ProtocolManagerFactory<P extends BaseInterceptor>

    • Method Detail

      • getPersister

        default org.apache.activemq.artemis.core.persistence.Persister<Message>[] getPersister()

      • createProtocolManager

        ProtocolManager createProtocolManager​(org.apache.activemq.artemis.core.server.ActiveMQServer server,
                                      Map<String,​Object> parameters,
                                      List<BaseInterceptor> incomingInterceptors,
                                      List<BaseInterceptor> outgoingInterceptors)
                               throws Exception
        When you create the ProtocolManager, you should filter out any interceptors that won't belong to this Protocol. For example don't send any core Interceptors Interceptor to Stomp * * *
        Parameters:
        server -
        incomingInterceptors -
        outgoingInterceptors -
        Returns:
        Throws:
        Exception

      • filterInterceptors

        List<P> filterInterceptors​(List<BaseInterceptor> interceptors)
        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 update
        services - 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.