com.hazelcast.cache.impl

Class AbstractCacheService

java.lang.Object

com.hazelcast.cache.impl.AbstractCacheService

All Implemented Interfaces:

ICacheService, EventPublishingService<Object,CacheEventListener>, ManagedService, MigrationAwareService, PostJoinAwareService, RemoteService

Direct Known Subclasses:

CacheService

public abstract class AbstractCacheService
extends Object
implements ICacheService, PostJoinAwareService

Field Summary

Fields

Modifier and Type	Field and Description
protected ConstructorFunction<String,CacheContext>	cacheContexesConstructorFunction
protected ConcurrentMap<String,CacheContext>	cacheContexts
protected ConstructorFunction<String,CacheStatisticsImpl>	cacheStatisticsConstructorFunction
protected ConcurrentMap<String,Closeable>	closeableListeners
protected ConcurrentMap<String,CacheConfig>	configs
protected NodeEngine	nodeEngine
protected ConcurrentMap<String,CacheOperationProvider>	operationProviderCache
protected ConcurrentMap<String,Set<Closeable>>	resources
protected CachePartitionSegment[]	segments
protected ConcurrentMap<String,CacheStatisticsImpl>	statistics

Fields inherited from interface com.hazelcast.cache.impl.ICacheService

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
AbstractCacheService()

Method Summary

Methods

Modifier and Type	Method and Description
void	addCacheResource(String name, Closeable resource)
void	beforeMigration(PartitionMigrationEvent event)
void	cacheEntryListenerDeregistered(String name, javax.cache.configuration.CacheEntryListenerConfiguration cacheEntryListenerConfiguration)
void	cacheEntryListenerRegistered(String name, javax.cache.configuration.CacheEntryListenerConfiguration cacheEntryListenerConfiguration)
void	clearPartitionReplica(int partitionId)
void	commitMigration(PartitionMigrationEvent event)
CacheConfig	createCacheConfigIfAbsent(CacheConfig config)
CacheStatisticsImpl	createCacheStatIfAbsent(String name)
DistributedObject	createDistributedObject(String objectName) Creates a distributed object.
protected abstract ICacheRecordStore	createNewRecordStore(String name, int partitionId)
CacheConfig	deleteCacheConfig(String name)
void	deleteCacheStat(String name)
void	deregisterAllListener(String name)
boolean	deregisterListener(String name, String registrationId)
void	destroyCache(String name, boolean isLocal, String callerUuid)
protected void	destroyCacheOnAllMembers(String name, String callerUuid)
void	destroyDistributedObject(String objectName) Destroys a distributed object.
protected void	destroySegments(String name)
void	dispatchEvent(Object event, CacheEventListener listener)
CacheSimpleConfig	findCacheConfig(String simpleName)
CacheConfig	getCacheConfig(String name)
Collection<CacheConfig>	getCacheConfigs()
CacheContext	getCacheContext(String name)
CacheOperationProvider	getCacheOperationProvider(String nameWithPrefix, InMemoryFormat inMemoryFormat) Creates cache operations according to the storage-type of the cache
ICacheRecordStore	getCacheRecordStore(String name, int partitionId)
NodeEngine	getNodeEngine()
ICacheRecordStore	getOrCreateCache(String name, int partitionId)
CacheContext	getOrCreateCacheContext(String name)
Operation	getPostJoinOperation() Post join operations must be lock free, meaning no locks at all: no partition locks, no key-based locks, no service level locks, no database interaction!
CachePartitionSegment	getSegment(int partitionId)
CacheStatisticsImpl	getStatistics(String name)
void	init(NodeEngine nodeEngine, Properties properties) Initializes this ManagedService
protected void	postInit(NodeEngine nodeEngine, Properties properties)
void	publishEvent(CacheEventContext cacheEventContext)
void	publishEvent(String cacheName, CacheEventSet eventSet, int orderKey)
String	registerListener(String name, CacheEventListener listener)
String	registerListener(String name, CacheEventListener listener, EventFilter eventFilter)
protected String	registerListenerInternal(String name, CacheEventListener listener, EventFilter eventFilter)
void	rollbackMigration(PartitionMigrationEvent event)
void	setManagementEnabled(CacheConfig cacheConfig, String cacheNameWithPrefix, boolean enabled)
void	setStatisticsEnabled(CacheConfig cacheConfig, String cacheNameWithPrefix, boolean enabled)
Data	toData(Object object)
Object	toObject(Object data)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.cache.impl.ICacheService

sendInvalidationEvent

Methods inherited from interface com.hazelcast.spi.ManagedService

reset, shutdown

Methods inherited from interface com.hazelcast.spi.MigrationAwareService

prepareReplicationOperation

Field Detail

configs

protected final ConcurrentMap<String,CacheConfig> configs

cacheContexts

protected final ConcurrentMap<String,CacheContext> cacheContexts

statistics

protected final ConcurrentMap<String,CacheStatisticsImpl> statistics

resources

protected final ConcurrentMap<String,Set<Closeable>> resources

closeableListeners

protected final ConcurrentMap<String,Closeable> closeableListeners

operationProviderCache

protected final ConcurrentMap<String,CacheOperationProvider> operationProviderCache

cacheContexesConstructorFunction

protected final ConstructorFunction<String,CacheContext> cacheContexesConstructorFunction

cacheStatisticsConstructorFunction

protected final ConstructorFunction<String,CacheStatisticsImpl> cacheStatisticsConstructorFunction

nodeEngine

protected NodeEngine nodeEngine

segments

protected CachePartitionSegment[] segments

Constructor Detail

AbstractCacheService

public AbstractCacheService()

Method Detail

init

public final void init(NodeEngine nodeEngine,
        Properties properties)

Description copied from interface: ManagedService

Initializes this ManagedService

Specified by:

init in interface ManagedService

Parameters:

nodeEngine - the NodeEngine that this ManagedService belongs to.

properties - the Properties. Can be used to pass settings to the service.

postInit

protected void postInit(NodeEngine nodeEngine,
            Properties properties)

createNewRecordStore

protected abstract ICacheRecordStore createNewRecordStore(String name,
                                     int partitionId)

createDistributedObject

public DistributedObject createDistributedObject(String objectName)

Description copied from interface: RemoteService

Creates a distributed object.

Specified by:

createDistributedObject in interface RemoteService

Parameters:

objectName - the name for the created distributed object

Returns:

the created distributed object

destroyDistributedObject

public void destroyDistributedObject(String objectName)

Description copied from interface: RemoteService

Destroys a distributed object.

Specified by:

destroyDistributedObject in interface RemoteService

Parameters:

objectName - the name of the distributed object to destroy

beforeMigration

public void beforeMigration(PartitionMigrationEvent event)

Specified by:

beforeMigration in interface MigrationAwareService

commitMigration

public void commitMigration(PartitionMigrationEvent event)

Specified by:

commitMigration in interface MigrationAwareService

rollbackMigration

public void rollbackMigration(PartitionMigrationEvent event)

Specified by:

rollbackMigration in interface MigrationAwareService

clearPartitionReplica

public void clearPartitionReplica(int partitionId)

Specified by:

clearPartitionReplica in interface MigrationAwareService

getOrCreateCache

public ICacheRecordStore getOrCreateCache(String name,
                                 int partitionId)

Specified by:

getOrCreateCache in interface ICacheService

getCacheRecordStore

public ICacheRecordStore getCacheRecordStore(String name,
                                    int partitionId)

Specified by:

getCacheRecordStore in interface ICacheService

getSegment

public CachePartitionSegment getSegment(int partitionId)

Specified by:

getSegment in interface ICacheService

destroySegments

protected void destroySegments(String name)

destroyCache

public void destroyCache(String name,
                boolean isLocal,
                String callerUuid)

Specified by:

destroyCache in interface ICacheService

destroyCacheOnAllMembers

protected void destroyCacheOnAllMembers(String name,
                            String callerUuid)

createCacheConfigIfAbsent

public CacheConfig createCacheConfigIfAbsent(CacheConfig config)

Specified by:

createCacheConfigIfAbsent in interface ICacheService

deleteCacheConfig

public CacheConfig deleteCacheConfig(String name)

Specified by:

deleteCacheConfig in interface ICacheService

createCacheStatIfAbsent

public CacheStatisticsImpl createCacheStatIfAbsent(String name)

Specified by:

createCacheStatIfAbsent in interface ICacheService

getCacheContext

public CacheContext getCacheContext(String name)

getOrCreateCacheContext

public CacheContext getOrCreateCacheContext(String name)

deleteCacheStat

public void deleteCacheStat(String name)

Specified by:

deleteCacheStat in interface ICacheService

setStatisticsEnabled

public void setStatisticsEnabled(CacheConfig cacheConfig,
                        String cacheNameWithPrefix,
                        boolean enabled)

Specified by:

setStatisticsEnabled in interface ICacheService

setManagementEnabled

public void setManagementEnabled(CacheConfig cacheConfig,
                        String cacheNameWithPrefix,
                        boolean enabled)

Specified by:

setManagementEnabled in interface ICacheService

getCacheConfig

public CacheConfig getCacheConfig(String name)

Specified by:

getCacheConfig in interface ICacheService

findCacheConfig

public CacheSimpleConfig findCacheConfig(String simpleName)

Specified by:

findCacheConfig in interface ICacheService

getCacheConfigs

public Collection<CacheConfig> getCacheConfigs()

Specified by:

getCacheConfigs in interface ICacheService

toObject

public Object toObject(Object data)

toData

public Data toData(Object object)

publishEvent

public void publishEvent(CacheEventContext cacheEventContext)

Specified by:

publishEvent in interface ICacheService

publishEvent

public void publishEvent(String cacheName,
                CacheEventSet eventSet,
                int orderKey)

Specified by:

publishEvent in interface ICacheService

getNodeEngine

public NodeEngine getNodeEngine()

Specified by:

getNodeEngine in interface ICacheService

dispatchEvent

public void dispatchEvent(Object event,
                 CacheEventListener listener)

Specified by:

dispatchEvent in interface EventPublishingService<Object,CacheEventListener>

registerListener

public String registerListener(String name,
                      CacheEventListener listener)

Specified by:

registerListener in interface ICacheService

registerListener

public String registerListener(String name,
                      CacheEventListener listener,
                      EventFilter eventFilter)

Specified by:

registerListener in interface ICacheService

registerListenerInternal

protected String registerListenerInternal(String name,
                              CacheEventListener listener,
                              EventFilter eventFilter)

deregisterListener

public boolean deregisterListener(String name,
                         String registrationId)

Specified by:

deregisterListener in interface ICacheService

deregisterAllListener

public void deregisterAllListener(String name)

Specified by:

deregisterAllListener in interface ICacheService

getStatistics

public CacheStatisticsImpl getStatistics(String name)

Specified by:

getStatistics in interface ICacheService

getCacheOperationProvider

public CacheOperationProvider getCacheOperationProvider(String nameWithPrefix,
                                               InMemoryFormat inMemoryFormat)

Description copied from interface: ICacheService

Creates cache operations according to the storage-type of the cache

Specified by:

getCacheOperationProvider in interface ICacheService

addCacheResource

public void addCacheResource(String name,
                    Closeable resource)

getPostJoinOperation

public Operation getPostJoinOperation()

Description copied from interface: PostJoinAwareService

Post join operations must be lock free, meaning no locks at all: no partition locks, no key-based locks, no service level locks, no database interaction!

Post join operations should return response, at least a null response.

Specified by:

getPostJoinOperation in interface PostJoinAwareService

Returns:

a response from the post join operation. Can be null.

cacheEntryListenerRegistered

public void cacheEntryListenerRegistered(String name,
                                javax.cache.configuration.CacheEntryListenerConfiguration cacheEntryListenerConfiguration)

cacheEntryListenerDeregistered

public void cacheEntryListenerDeregistered(String name,
                                  javax.cache.configuration.CacheEntryListenerConfiguration cacheEntryListenerConfiguration)