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

Class AbstractProtocolManagerFactory<P extends BaseInterceptor>

java.lang.Object
org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManagerFactory<P>
All Implemented Interfaces:
ProtocolManagerFactory<P>
public abstract class AbstractProtocolManagerFactory<P extends BaseInterceptor> extends Object implements ProtocolManagerFactory<P>

  • Constructor Details

    • AbstractProtocolManagerFactory

      public AbstractProtocolManagerFactory()

  • Method Details

    • internalFilterInterceptors

      protected List<P> internalFilterInterceptors(Class<P> type, List<? extends BaseInterceptor> listIn)
      This method exists because java templates won't store the type of P at runtime. So it's not possible to write a generic method with having the Class Type. This will serve as a tool for sub classes to filter properly* * *
      Parameters:
      type -
      listIn -
      Returns:

    • loadProtocolServices

      public void loadProtocolServices(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services)
      Specified by:
      loadProtocolServices in interface ProtocolManagerFactory<P extends BaseInterceptor>

    • updateProtocolServices

      public void updateProtocolServices(org.apache.activemq.artemis.core.server.ActiveMQServer server, List<org.apache.activemq.artemis.core.server.ActiveMQComponent> services) throws Exception
      Description copied from interface: ProtocolManagerFactory
      Provides an entry point for the server to trigger the protocol manager factory to update its protocol services based on updates to server configuration.
      Specified by:
      updateProtocolServices in interface ProtocolManagerFactory<P extends BaseInterceptor>
      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.