Package org.apache.activemq.artemis.core.server

Interface ServiceRegistry

All Known Implementing Classes:
ServiceRegistryImpl
public interface ServiceRegistry
A holder for common services leveraged by the broker.

  • Method Details

    • getPageExecutorService

      ExecutorService getPageExecutorService()

    • setPageExecutorService

      void setPageExecutorService(ExecutorService executorService)
      Notice that if you want to provide your own PageExecutor, you should limit the number of threads to the number of parallel reads you want to perform on paging

    • getExecutorService

      ExecutorService getExecutorService()

    • setExecutorService

      void setExecutorService(ExecutorService executorService)

    • getIOExecutorService

      ExecutorService getIOExecutorService()

    • setIOExecutorService

      void setIOExecutorService(ExecutorService ioExecutorService)

    • getScheduledExecutorService

      ScheduledExecutorService getScheduledExecutorService()

    • setScheduledExecutorService

      void setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)

    • addConnectorService

      void addConnectorService(ConnectorServiceFactory connectorServiceFactory, ConnectorServiceConfiguration configuration)

    • removeConnectorService

      void removeConnectorService(ConnectorServiceConfiguration configuration)

    • getConnectorServices

      Collection<Pair<ConnectorServiceFactory,ConnectorServiceConfiguration>> getConnectorServices(List<ConnectorServiceConfiguration> configs)
      Get a collection of paired org.apache.activemq.artemis.core.server.ConnectorServiceFactory and org.apache.activemq.artemis.core.config.ConnectorServiceConfiguration instances.

    • getConnectorService

      ConnectorServiceFactory getConnectorService(ConnectorServiceConfiguration configuration)
      Get connector service for a given configuration.
      Parameters:
      configuration - The connector service configuration.
      Returns:
      an instance of the connector service factory

    • addIncomingInterceptor

      void addIncomingInterceptor(BaseInterceptor interceptor)

    • getIncomingInterceptors

      List<BaseInterceptor> getIncomingInterceptors(List<String> classNames)
      Get a list of org.apache.activemq.artemis.api.core.BaseInterceptor instances

    • addOutgoingInterceptor

      void addOutgoingInterceptor(BaseInterceptor interceptor)

    • getOutgoingInterceptors

      List<BaseInterceptor> getOutgoingInterceptors(List<String> classNames)
      Get a list of org.apache.activemq.artemis.api.core.BaseInterceptor instances

    • getDivertTransformer

      Transformer getDivertTransformer(String name, TransformerConfiguration transformerConfiguration)
      Get an instance of org.apache.activemq.artemis.core.server.transformer.Transformer for a divert
      Parameters:
      name - the name of divert for which the transformer will be used
      transformerConfiguration - the transformer configuration

    • addDivertTransformer

      void addDivertTransformer(String name, Transformer transformer)

    • removeDivertTransformer

      void removeDivertTransformer(String name)

    • getBridgeTransformer

      Transformer getBridgeTransformer(String name, TransformerConfiguration transformerConfiguration)
      Get an instance of org.apache.activemq.artemis.core.server.transformer.Transformer for a bridge
      Parameters:
      name - the name of bridge for which the transformer will be used
      transformerConfiguration - the transformer configuration

    • addBridgeTransformer

      void addBridgeTransformer(String name, Transformer transformer)

    • getFederationTransformer

      Transformer getFederationTransformer(String name, TransformerConfiguration transformerConfiguration)
      Get an instance of org.apache.activemq.artemis.core.server.transformer.Transformer for federation
      Parameters:
      name - the name of bridge for which the transformer will be used
      transformerConfiguration - the transformer configuration

    • addFederationTransformer

      void addFederationTransformer(String name, Transformer transformer)

    • getAcceptorFactory

      AcceptorFactory getAcceptorFactory(String name, String className)
      Get an instance of org.apache.activemq.artemis.spi.core.remoting.AcceptorFactory
      Parameters:
      name - the name of acceptor for which the factory will be used
      className - the fully qualified name of the factory implementation (can be null)

    • addAcceptorFactory

      void addAcceptorFactory(String name, AcceptorFactory acceptorFactory)