Package org.infinispan.factories

Class ComponentRegistry

java.lang.Object

org.infinispan.factories.AbstractComponentRegistry

org.infinispan.factories.ComponentRegistry

All Implemented Interfaces:

Lifecycle

public class ComponentRegistry
extends AbstractComponentRegistry

Named cache specific components

Since:

4.0

Author:

Manik Surtani

Field Summary

Fields

Modifier and Type	Field	Description
protected ComponentRef<InternalEntryFactory>	internalEntryFactory

Fields inherited from class org.infinispan.factories.AbstractComponentRegistry

state

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	bootstrapComponents()	This is a good place to register components that don't have any dependency.
void	cacheComponents()	Invoked last after all services are wired
static <T> T	componentOf(Cache<?,?> cache, Class<T> type)
static <T> T	componentOf(Cache<?,?> cache, Class<T> type, String name)
protected CompletionStage<Void>	delayStart()	The ComponentRegistry may delay the start after a cluster shutdown.
ComponentRef<org.infinispan.xsite.BackupReceiver>	getBackupReceiver()
ComponentRef<org.infinispan.xsite.BackupSender>	getBackupSender()
ComponentRef<BlockingManager>	getBlockingManager()
ComponentRef<AdvancedCache>	getCache()
ByteString	getCacheByteString()
StreamingMarshaller	getCacheMarshaller()	Deprecated, for removal: This API element is subject to removal in a future version.
String	getCacheName()
ComponentRef<CacheNotifier>	getCacheNotifier()
protected ClassLoader	getClassLoader()
ComponentRef<ClusterCacheNotifier>	getClusterCacheNotifier()
ComponentRef<ClusterPublisherManager>	getClusterPublisherManager()
ComponentRef<CommandAckCollector>	getCommandAckCollector()
CommandsFactory	getCommandsFactory()	Caching shortcut for #getLocalComponent(CommandsFactory.class);
final <T> T	getComponent(String componentTypeName, String name, boolean nameIsFQCN)
Configuration	getConfiguration()
ComponentRef<org.infinispan.conflict.impl.InternalConflictManager>	getConflictManager()
DistributionManager	getDistributionManager()	Caching shortcut for #getComponent(DistributionManager.class);
final GlobalComponentRegistry	getGlobalComponentRegistry()
ComponentRef<AsyncInterceptorChain>	getInterceptorChain()
ComponentRef<InternalDataContainer>	getInternalDataContainer()
ComponentRef<InternalEntryFactory>	getInternalEntryFactory()
StreamingMarshaller	getInternalMarshaller()	Caching shortcut for #getComponent(StreamingMarshaller.class, INTERNAL_MARSHALLER);
ComponentRef<InvocationContextFactory>	getInvocationContextFactory()
ComponentRef<IracManager>	getIracManager()
ComponentRef<IracTombstoneManager>	getIracTombstoneManager()
ComponentRef<IracVersionGenerator>	getIracVersionGenerator()
ComponentRef<ClusterPublisherManager>	getLocalClusterPublisherManager()
final <T> T	getLocalComponent(Class<T> componentType)
final <T> T	getLocalComponent(String componentTypeName, String name, boolean nameIsFQCN)
ComponentRef<LocalPublisherManager>	getLocalPublisherManager()
ComponentRef<LockManager>	getLockManager()
protected org.infinispan.util.logging.Log	getLog()
protected String	getName()
protected final <T> T	getOrCreateComponent(Class<T> componentClass, String name, boolean nameIsFQCN)
org.infinispan.remoting.inboundhandler.PerCacheInboundInvocationHandler	getPerCacheInboundInvocationHandler()	Caching shortcut for #getComponent(PerCacheInboundInvocationHandler.class);
PersistenceMarshaller	getPersistenceMarshaller()	Caching shortcut for #getComponent(PersistenceMarshaller.class, PERSISTENCE_MARSHALLER);
ComponentRef<PublisherHandler>	getPublisherHandler()
ComponentRef<RecoveryManager>	getRecoveryManager()
ResponseGenerator	getResponseGenerator()	Caching shortcut for #getComponent(ResponseGenerator.class);
ComponentRef<RpcManager>	getRpcManager()
org.infinispan.statetransfer.StateTransferLock	getStateTransferLock()	Caching shortcut for #getComponent(StateTransferManager.class);
org.infinispan.statetransfer.StateTransferManager	getStateTransferManager()	Caching shortcut for #getComponent(StateTransferManager.class);
ComponentRef<TakeOfflineManager>	getTakeOfflineManager()
TimeService	getTimeService()
final TransactionTable	getTransactionTable()
final ComponentRef<TransactionTable>	getTransactionTableRef()
VersionGenerator	getVersionGenerator()	Caching shortcut for #getLocalComponent(VersionGenerator.class)
ComponentRef<XSiteStateTransferManager>	getXSiteStateTransferManager()
static <K, V> ComponentRegistry	of(Cache<K,V> cache)
protected void	postStart()
protected void	postStop()
protected void	preStart()
protected void	preStop()
final void	registerVersionGenerator(NumericVersionGenerator newVersionGenerator)
void	rewire()	Rewires components.
void	start()	This starts the components in the registry, connecting to channels, starting service threads, etc.

Methods inherited from class org.infinispan.factories.AbstractComponentRegistry

addShutdownHook, getComponent, getComponent, getComponent, getComponent, getOptionalComponent, getOrCreateComponent, getOrCreateComponent, getStatus, registerComponent, registerComponent, registerComponent, registerComponentInternal, registerNonVolatileComponent, removeShutdownHook, stop, wireDependencies, wireDependencies

Methods inherited from class java.lang.Object

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

Field Details

internalEntryFactory

protected ComponentRef<InternalEntryFactory> internalEntryFactory

Constructor Details

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 Details

getClassLoader

protected ClassLoader getClassLoader()

Specified by:

getClassLoader in class AbstractComponentRegistry

getLog

protected org.infinispan.util.logging.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)

getGlobalComponentRegistry

public final GlobalComponentRegistry getGlobalComponentRegistry()

getOrCreateComponent

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

Overrides:

getOrCreateComponent in class AbstractComponentRegistry

start

public void start()

Description copied from class: AbstractComponentRegistry

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

Specified by:

start in interface Lifecycle

Overrides:

start in class AbstractComponentRegistry

delayStart

protected CompletionStage<Void> delayStart()

The ComponentRegistry may delay the start after a cluster shutdown. The component waits for the installation of the previous stable topology to start. Caches that do not need state transfer or are private do not need to delay the start.

Specified by:

delayStart in class AbstractComponentRegistry

getName

protected String getName()

Specified by:

getName in class AbstractComponentRegistry

preStart

protected void preStart()

Specified by:

preStart in class AbstractComponentRegistry

postStart

protected void postStart()

Specified by:

postStart in class AbstractComponentRegistry

preStop

protected void preStop()

Specified by:

preStop in class AbstractComponentRegistry

postStop

protected void postStop()

Specified by:

postStop in class AbstractComponentRegistry

rewire

public void rewire()

Description copied from class: AbstractComponentRegistry

Rewires components. Used to rewire components in the CR if a cache has been stopped (moved to state TERMINATED), which would (almost) empty the registry of components. Rewiring will re-inject all dependencies so that the cache can be started again.

Overrides:

rewire in class AbstractComponentRegistry

getTimeService

public TimeService getTimeService()

Specified by:

getTimeService in class AbstractComponentRegistry

getCacheName

public String getCacheName()

getCacheMarshaller

@Deprecated(forRemoval=true)
public StreamingMarshaller getCacheMarshaller()

Deprecated, for removal: This API element is subject to removal in a future version.

getInternalMarshaller

public StreamingMarshaller getInternalMarshaller()

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

getPersistenceMarshaller

public PersistenceMarshaller getPersistenceMarshaller()

Caching shortcut for #getComponent(PersistenceMarshaller.class, PERSISTENCE_MARSHALLER);

getStateTransferManager

public org.infinispan.statetransfer.StateTransferManager getStateTransferManager()

Caching shortcut for #getComponent(StateTransferManager.class);

getDistributionManager

public DistributionManager getDistributionManager()

Caching shortcut for #getComponent(DistributionManager.class);

getResponseGenerator

public ResponseGenerator getResponseGenerator()

Caching shortcut for #getComponent(ResponseGenerator.class);

getCommandsFactory

public CommandsFactory getCommandsFactory()

Caching shortcut for #getLocalComponent(CommandsFactory.class);

getStateTransferLock

public org.infinispan.statetransfer.StateTransferLock getStateTransferLock()

Caching shortcut for #getComponent(StateTransferManager.class);

getVersionGenerator

public VersionGenerator getVersionGenerator()

Caching shortcut for #getLocalComponent(VersionGenerator.class)

getPerCacheInboundInvocationHandler

public org.infinispan.remoting.inboundhandler.PerCacheInboundInvocationHandler getPerCacheInboundInvocationHandler()

Caching shortcut for #getComponent(PerCacheInboundInvocationHandler.class);

bootstrapComponents

protected void bootstrapComponents()

This is a good place to register components that don't have any dependency.

cacheComponents

public void cacheComponents()

Invoked last after all services are wired

getTransactionTable

public final TransactionTable getTransactionTable()

getTransactionTableRef

public final ComponentRef<TransactionTable> getTransactionTableRef()

registerVersionGenerator

public final void registerVersionGenerator(NumericVersionGenerator newVersionGenerator)

getCache

public ComponentRef<AdvancedCache> getCache()

getInterceptorChain

public ComponentRef<AsyncInterceptorChain> getInterceptorChain()

getBackupSender

public ComponentRef<org.infinispan.xsite.BackupSender> getBackupSender()

getBlockingManager

public ComponentRef<BlockingManager> getBlockingManager()

getClusterPublisherManager

public ComponentRef<ClusterPublisherManager> getClusterPublisherManager()

getLocalClusterPublisherManager

public ComponentRef<ClusterPublisherManager> getLocalClusterPublisherManager()

getTakeOfflineManager

public ComponentRef<TakeOfflineManager> getTakeOfflineManager()

getIracManager

public ComponentRef<IracManager> getIracManager()

getIracVersionGenerator

public ComponentRef<IracVersionGenerator> getIracVersionGenerator()

getIracTombstoneManager

public ComponentRef<IracTombstoneManager> getIracTombstoneManager()

getCacheByteString

public ByteString getCacheByteString()

getCacheNotifier

public ComponentRef<CacheNotifier> getCacheNotifier()

getConfiguration

public Configuration getConfiguration()

getConflictManager

public ComponentRef<org.infinispan.conflict.impl.InternalConflictManager> getConflictManager()

getClusterCacheNotifier

public ComponentRef<ClusterCacheNotifier> getClusterCacheNotifier()

getCommandAckCollector

public ComponentRef<CommandAckCollector> getCommandAckCollector()

getInternalDataContainer

public ComponentRef<InternalDataContainer> getInternalDataContainer()

getInternalEntryFactory

public ComponentRef<InternalEntryFactory> getInternalEntryFactory()

getInvocationContextFactory

public ComponentRef<InvocationContextFactory> getInvocationContextFactory()

getLocalPublisherManager

public ComponentRef<LocalPublisherManager> getLocalPublisherManager()

getPublisherHandler

public ComponentRef<PublisherHandler> getPublisherHandler()

getLockManager

public ComponentRef<LockManager> getLockManager()

getRecoveryManager

public ComponentRef<RecoveryManager> getRecoveryManager()

getRpcManager

public ComponentRef<RpcManager> getRpcManager()

getXSiteStateTransferManager

public ComponentRef<XSiteStateTransferManager> getXSiteStateTransferManager()

getBackupReceiver

public ComponentRef<org.infinispan.xsite.BackupReceiver> getBackupReceiver()

of

public static <K,
V> ComponentRegistry of(Cache<K,V> cache)

componentOf

public static <T> T componentOf(Cache<?,?> cache,
 Class<T> type)

componentOf

public static <T> T componentOf(Cache<?,?> cache,
 Class<T> type,
 String name)