org.apache.activemq.artemis.core.server.impl

Class ServiceRegistryImpl

java.lang.Object

org.apache.activemq.artemis.core.server.impl.ServiceRegistryImpl

All Implemented Interfaces:

ServiceRegistry

public class ServiceRegistryImpl
extends Object
implements ServiceRegistry

Constructor Summary

Constructors

Constructor and Description
ServiceRegistryImpl()

Method Summary

Modifier and Type	Method and Description
void	addAcceptorFactory(String name, AcceptorFactory acceptorFactory)
void	addBridgeTransformer(String name, Transformer transformer)
void	addConnectorService(ConnectorServiceFactory connectorServiceFactory, ConnectorServiceConfiguration configuration)
void	addDivertTransformer(String name, Transformer transformer)
void	addIncomingInterceptor(BaseInterceptor interceptor)
void	addOutgoingInterceptor(BaseInterceptor interceptor)
AcceptorFactory	getAcceptorFactory(String name, String className) Get an instance of org.apache.activemq.artemis.spi.core.remoting.AcceptorFactory
Transformer	getBridgeTransformer(String name, String className) Get an instance of org.apache.activemq.artemis.core.server.cluster.Transformer for a bridge
ConnectorServiceFactory	getConnectorService(ConnectorServiceConfiguration configuration) Get connector service for a given configuration.
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.
Transformer	getDivertTransformer(String name, String className) Get an instance of org.apache.activemq.artemis.core.server.cluster.Transformer for a divert
ExecutorService	getExecutorService()
List<BaseInterceptor>	getIncomingInterceptors(List<String> classNames) Get a list of org.apache.activemq.artemis.api.core.BaseInterceptor instances
ExecutorService	getIOExecutorService()
List<BaseInterceptor>	getOutgoingInterceptors(List<String> classNames) Get a list of org.apache.activemq.artemis.api.core.BaseInterceptor instances
ScheduledExecutorService	getScheduledExecutorService()
<T> T	loadClass(String className)
void	removeConnectorService(ConnectorServiceConfiguration configuration)
void	setExecutorService(ExecutorService executorService)
void	setIOExecutorService(ExecutorService ioExecutorService)
void	setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServiceRegistryImpl

public ServiceRegistryImpl()

Method Detail

getExecutorService

public ExecutorService getExecutorService()

Specified by:

getExecutorService in interface ServiceRegistry

setExecutorService

public void setExecutorService(ExecutorService executorService)

Specified by:

setExecutorService in interface ServiceRegistry

getScheduledExecutorService

public ScheduledExecutorService getScheduledExecutorService()

Specified by:

getScheduledExecutorService in interface ServiceRegistry

setScheduledExecutorService

public void setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)

Specified by:

setScheduledExecutorService in interface ServiceRegistry

addConnectorService

public void addConnectorService(ConnectorServiceFactory connectorServiceFactory,
                                ConnectorServiceConfiguration configuration)

Specified by:

addConnectorService in interface ServiceRegistry

removeConnectorService

public void removeConnectorService(ConnectorServiceConfiguration configuration)

Specified by:

removeConnectorService in interface ServiceRegistry

getConnectorServices

public Collection<Pair<ConnectorServiceFactory,ConnectorServiceConfiguration>> getConnectorServices(List<ConnectorServiceConfiguration> configs)

Description copied from interface: ServiceRegistry

Get a collection of paired org.apache.activemq.artemis.core.server.ConnectorServiceFactory and org.apache.activemq.artemis.core.config.ConnectorServiceConfiguration instances.

Specified by:

getConnectorServices in interface ServiceRegistry

Returns:

getConnectorService

public ConnectorServiceFactory getConnectorService(ConnectorServiceConfiguration configuration)

Description copied from interface: ServiceRegistry

Get connector service for a given configuration.

Specified by:

getConnectorService in interface ServiceRegistry

Parameters:

configuration - The connector service configuration.

Returns:

an instance of the connector service factory.

addIncomingInterceptor

public void addIncomingInterceptor(BaseInterceptor interceptor)

Specified by:

addIncomingInterceptor in interface ServiceRegistry

getIncomingInterceptors

public List<BaseInterceptor> getIncomingInterceptors(List<String> classNames)

Description copied from interface: ServiceRegistry

Get a list of org.apache.activemq.artemis.api.core.BaseInterceptor instances

Specified by:

getIncomingInterceptors in interface ServiceRegistry

Returns:

addOutgoingInterceptor

public void addOutgoingInterceptor(BaseInterceptor interceptor)

Specified by:

addOutgoingInterceptor in interface ServiceRegistry

getOutgoingInterceptors

public List<BaseInterceptor> getOutgoingInterceptors(List<String> classNames)

Description copied from interface: ServiceRegistry

Get a list of org.apache.activemq.artemis.api.core.BaseInterceptor instances

Specified by:

getOutgoingInterceptors in interface ServiceRegistry

Returns:

addDivertTransformer

public void addDivertTransformer(String name,
                                 Transformer transformer)

Specified by:

addDivertTransformer in interface ServiceRegistry

getDivertTransformer

public Transformer getDivertTransformer(String name,
                                        String className)

Description copied from interface: ServiceRegistry

Get an instance of org.apache.activemq.artemis.core.server.cluster.Transformer for a divert

Specified by:

getDivertTransformer in interface ServiceRegistry

Parameters:

name - the name of divert for which the transformer will be used

className - the fully qualified name of the transformer implementation (can be null)

Returns:

getIOExecutorService

public ExecutorService getIOExecutorService()

Specified by:

getIOExecutorService in interface ServiceRegistry

setIOExecutorService

public void setIOExecutorService(ExecutorService ioExecutorService)

Specified by:

setIOExecutorService in interface ServiceRegistry

addBridgeTransformer

public void addBridgeTransformer(String name,
                                 Transformer transformer)

Specified by:

addBridgeTransformer in interface ServiceRegistry

getBridgeTransformer

public Transformer getBridgeTransformer(String name,
                                        String className)

Description copied from interface: ServiceRegistry

Get an instance of org.apache.activemq.artemis.core.server.cluster.Transformer for a bridge

Specified by:

getBridgeTransformer in interface ServiceRegistry

Parameters:

name - the name of bridge for which the transformer will be used

className - the fully qualified name of the transformer implementation (can be null)

Returns:

getAcceptorFactory

public AcceptorFactory getAcceptorFactory(String name,
                                          String className)

Description copied from interface: ServiceRegistry

Get an instance of org.apache.activemq.artemis.spi.core.remoting.AcceptorFactory

Specified by:

getAcceptorFactory in interface ServiceRegistry

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)

Returns:

addAcceptorFactory

public void addAcceptorFactory(String name,
                               AcceptorFactory acceptorFactory)

Specified by:

addAcceptorFactory in interface ServiceRegistry

loadClass

public <T> T loadClass(String className)