org.infinispan.factories

Class ComponentRegistry

java.lang.Object

org.infinispan.factories.AbstractComponentRegistry

org.infinispan.factories.ComponentRegistry

All Implemented Interfaces:

Cloneable, Lifecycle

public class ComponentRegistry
extends AbstractComponentRegistry

Named cache specific components

Since:

4.0

Author:

Manik Surtani

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.factories.AbstractComponentRegistry

AbstractComponentRegistry.Component

Field Summary

Fields

Modifier and Type	Field and Description
protected WeakReference<ClassLoader>	defaultClassLoader

Fields inherited from class org.infinispan.factories.AbstractComponentRegistry

DEBUG_DEPENDENCIES, state

Constructor Summary

Constructors

Constructor and Description
ComponentRegistry(String cacheName, Configuration configuration, AdvancedCache<?,?> cache, GlobalComponentRegistry globalComponents, ClassLoader defaultClassLoader) Creates an instance of the component registry.

Method Summary

Methods

Modifier and Type	Method and Description
void	cacheComponents() Invoked last after all services are wired
protected AbstractComponentFactory	createComponentFactoryInternal(Class<?> componentClass, String cfClass)
StreamingMarshaller	getCacheMarshaller() Caching shortcut for #getComponent(StreamingMarshaller.class, KnownComponentNames.CACHE_MARSHALLER);
String	getCacheName()
protected ClassLoader	getClassLoader()
CommandsFactory	getCommandsFactory() Caching shortcut for #getLocalComponent(CommandsFactory.class);
<T> T	getComponent(String componentTypeName, String name, boolean nameIsFQCN)
ComponentMetadataRepo	getComponentMetadataRepo()
protected AbstractComponentFactory	getFactory(Class<?> componentClass) Retrieves a component factory instance capable of constructing components of a specified type.
GlobalComponentRegistry	getGlobalComponentRegistry()
<T> T	getLocalComponent(Class<T> componentType)
<T> T	getLocalComponent(String componentTypeName, String name, boolean nameIsFQCN)
protected Log	getLog()
protected <T> T	getOrCreateComponent(Class<T> componentClass, String name, boolean nameIsFQCN)
ResponseGenerator	getResponseGenerator() Caching shortcut for #getComponent(ResponseGenerator.class);
StateTransferLock	getStateTransferLock() Caching shortcut for #getComponent(StateTransferManager.class);
StateTransferManager	getStateTransferManager() Caching shortcut for #getComponent(StateTransferManager.class);
TimeService	getTimeService()
TotalOrderManager	getTotalOrderManager()
protected AbstractComponentRegistry.Component	lookupComponent(String componentClassName, String name, boolean nameIsFQCN)
protected AbstractComponentRegistry.Component	lookupLocalComponent(String componentClassName, String name, boolean nameIsFQCN)
protected void	registerComponentInternal(Object component, String name, boolean nameIsFQCN)
void	setCacheManagerNotifier(CacheManagerNotifier cacheManagerNotifier)
void	start() This starts the components in the cache, connecting to channels, starting service threads, etc.
void	stop() Stops the cache and sets the cache status to ComponentStatus.TERMINATED once it is done.

Methods inherited from class org.infinispan.factories.AbstractComponentRegistry

addShutdownHook, clone, getComponent, getComponent, getComponent, getComponent, getConfiguration, getOrCreateComponent, getOrCreateComponent, getRegisteredComponents, getStatus, invocationsAllowed, registerComponent, registerComponent, registerComponent, registerDefaultClassLoader, registerNonVolatileComponent, registerNonVolatileComponent, registerNullComponent, removeShutdownHook, resetVolatileComponents, rewire, throwStackAwareConfigurationException, wireDependencies

Methods inherited from class java.lang.Object

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

Field Detail

defaultClassLoader

protected final WeakReference<ClassLoader> defaultClassLoader

Constructor Detail

ComponentRegistry

public ComponentRegistry(String cacheName,
                 Configuration configuration,
                 AdvancedCache<?,?> cache,
                 GlobalComponentRegistry globalComponents,
                 ClassLoader defaultClassLoader)

Creates an instance of the component registry. The configuration passed in is automatically registered.

Parameters:

configuration - configuration with which this is created

cache - cache

globalComponents - Shared Component Registry to delegate to

Method Detail

setCacheManagerNotifier

public void setCacheManagerNotifier(CacheManagerNotifier cacheManagerNotifier)

getClassLoader

protected ClassLoader getClassLoader()

Specified by:

getClassLoader in class AbstractComponentRegistry

getLog

protected Log getLog()

Specified by:

getLog in class AbstractComponentRegistry

getComponent

public final <T> T getComponent(String componentTypeName,
                 String name,
                 boolean nameIsFQCN)

Overrides:

getComponent in class AbstractComponentRegistry

getLocalComponent

public final <T> T getLocalComponent(String componentTypeName,
                      String name,
                      boolean nameIsFQCN)

getLocalComponent

public final <T> T getLocalComponent(Class<T> componentType)

lookupComponent

protected final AbstractComponentRegistry.Component lookupComponent(String componentClassName,
                                                  String name,
                                                  boolean nameIsFQCN)

Overrides:

lookupComponent in class AbstractComponentRegistry

lookupLocalComponent

protected final AbstractComponentRegistry.Component lookupLocalComponent(String componentClassName,
                                                       String name,
                                                       boolean nameIsFQCN)

getGlobalComponentRegistry

public final GlobalComponentRegistry getGlobalComponentRegistry()

getOrCreateComponent

protected final <T> T getOrCreateComponent(Class<T> componentClass,
                         String name,
                         boolean nameIsFQCN)

Overrides:

getOrCreateComponent in class AbstractComponentRegistry

getFactory

protected AbstractComponentFactory getFactory(Class<?> componentClass)

Description copied from class: AbstractComponentRegistry

Retrieves a component factory instance capable of constructing components of a specified type. If the factory doesn't exist in the registry, one is created.

Overrides:

getFactory in class AbstractComponentRegistry

Parameters:

componentClass - type of component to construct

Returns:

component factory capable of constructing such components

registerComponentInternal

protected final void registerComponentInternal(Object component,
                             String name,
                             boolean nameIsFQCN)

Overrides:

registerComponentInternal in class AbstractComponentRegistry

createComponentFactoryInternal

protected AbstractComponentFactory createComponentFactoryInternal(Class<?> componentClass,
                                                      String cfClass)

Overrides:

createComponentFactoryInternal in class AbstractComponentRegistry

start

public void start()

Description copied from class: AbstractComponentRegistry

This starts the components in the cache, connecting to channels, starting service threads, etc. If the cache is not in the ComponentStatus.INITIALIZING state, it will be initialized first.

Specified by:

start in interface Lifecycle

Overrides:

start in class AbstractComponentRegistry

stop

public void stop()

Description copied from class: AbstractComponentRegistry

Stops the cache and sets the cache status to ComponentStatus.TERMINATED once it is done. If the cache is not in the ComponentStatus.RUNNING state, this is a no-op.

Specified by:

stop in interface Lifecycle

Overrides:

stop in class AbstractComponentRegistry

getTimeService

public TimeService getTimeService()

Specified by:

getTimeService in class AbstractComponentRegistry

getCacheName

public String getCacheName()

getCacheMarshaller

public StreamingMarshaller getCacheMarshaller()

Caching shortcut for #getComponent(StreamingMarshaller.class, KnownComponentNames.CACHE_MARSHALLER);

getStateTransferManager

public StateTransferManager getStateTransferManager()

Caching shortcut for #getComponent(StateTransferManager.class);

getResponseGenerator

public ResponseGenerator getResponseGenerator()

Caching shortcut for #getComponent(ResponseGenerator.class);

getCommandsFactory

public CommandsFactory getCommandsFactory()

Caching shortcut for #getLocalComponent(CommandsFactory.class);

getStateTransferLock

public StateTransferLock getStateTransferLock()

Caching shortcut for #getComponent(StateTransferManager.class);

cacheComponents

public void cacheComponents()

Invoked last after all services are wired

getComponentMetadataRepo

public ComponentMetadataRepo getComponentMetadataRepo()

Specified by:

getComponentMetadataRepo in class AbstractComponentRegistry

getTotalOrderManager

public final TotalOrderManager getTotalOrderManager()