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 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
-
Methods inherited from class org.infinispan.factories.AbstractComponentRegistry
addShutdownHook, getComponent, getComponent, getComponent, getComponent, getOptionalComponent, getOrCreateComponent, getOrCreateComponent, getStatus, registerComponent, registerComponent, registerComponent, registerComponentInternal, registerDefaultClassLoader, registerNonVolatileComponent, removeShutdownHook, stop, wireDependencies, wireDependencies
-
-
-
-
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 createdcache
- cacheglobalComponents
- Shared Component Registry to delegate to
-
-
Method Detail
-
getClassLoader
protected ClassLoader getClassLoader()
- Specified by:
getClassLoader
in classAbstractComponentRegistry
-
getLog
protected org.infinispan.util.logging.Log getLog()
- Specified by:
getLog
in classAbstractComponentRegistry
-
getComponent
public final <T> T getComponent(String componentTypeName, String name, boolean nameIsFQCN)
- Overrides:
getComponent
in classAbstractComponentRegistry
-
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 classAbstractComponentRegistry
-
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 theComponentStatus.INITIALIZING
state, it will be initialized first.- Specified by:
start
in interfaceLifecycle
- Overrides:
start
in classAbstractComponentRegistry
-
getName
protected String getName()
- Specified by:
getName
in classAbstractComponentRegistry
-
preStart
protected void preStart()
- Specified by:
preStart
in classAbstractComponentRegistry
-
postStart
protected void postStart()
- Specified by:
postStart
in classAbstractComponentRegistry
-
preStop
protected void preStop()
- Specified by:
preStop
in classAbstractComponentRegistry
-
postStop
protected void postStop()
- Specified by:
postStop
in classAbstractComponentRegistry
-
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 classAbstractComponentRegistry
-
getTimeService
public TimeService getTimeService()
- Specified by:
getTimeService
in classAbstractComponentRegistry
-
getCacheName
public String getCacheName()
-
getCacheMarshaller
@Deprecated public StreamingMarshaller getCacheMarshaller()
Deprecated.
-
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()
-
getBiasManager
public ComponentRef<BiasManager> getBiasManager()
-
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()
-
getOrderedUpdatesManager
public ComponentRef<org.infinispan.persistence.manager.OrderedUpdatesManager> getOrderedUpdatesManager()
-
getRecoveryManager
public ComponentRef<RecoveryManager> getRecoveryManager()
-
getRpcManager
public ComponentRef<RpcManager> getRpcManager()
-
getXSiteStateTransferManager
public ComponentRef<XSiteStateTransferManager> getXSiteStateTransferManager()
-
getBackupReceiver
public ComponentRef<org.infinispan.xsite.BackupReceiver> getBackupReceiver()
-
-