com.hazelcast.cache.impl

Class CacheService

java.lang.Object

com.hazelcast.cache.impl.AbstractCacheService

com.hazelcast.cache.impl.CacheService

All Implemented Interfaces:

ICacheService, EventPublishingService<Object,CacheEventListener>, ManagedService, MigrationAwareService, PartitionAwareService, PostJoinAwareService, QuorumAwareService, RemoteService, SplitBrainHandlerService

public class CacheService
extends AbstractCacheService

Cache Service is the main access point of JCache implementation.

This service is responsible for:

• Creating and/or accessing the named CacheRecordStore.
• Creating/Deleting the cache configuration of the named ICache.
• Registering/Deregistering of cache listeners.
• Publish/dispatch cache events.
• Enabling/Disabling statistic and management.
• Data migration commit/rollback through MigrationAwareService.

WARNING:This service is an optionally registered service which is enabled when JCache is located on the classpath, as determined by JCacheDetector.isJcacheAvailable(ClassLoader).

If registered, it will provide all the above cache operations for all partitions of the node which it is registered on.

Distributed Cache Name is used for providing a unique name to a cache object to overcome cache manager scoping which depends on URI and class loader parameters. It's a simple concatenation of CacheNamePrefix and cache name where CacheNamePrefix is calculated by each cache manager using AbstractHazelcastCacheManager.cacheNamePrefix().

Field Summary

Fields inherited from class com.hazelcast.cache.impl.AbstractCacheService

cacheContexesConstructorFunction, cacheContexts, cacheEventHandler, cacheSplitBrainHandler, cacheStatisticsConstructorFunction, closeableListeners, configs, logger, nodeEngine, operationProviderCache, resources, segments, statistics

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

CACHE_SUPPORT_NOT_AVAILABLE_ERROR_MESSAGE, SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
CacheService()

Method Summary

Modifier and Type	Method and Description
protected ICacheRecordStore	createNewRecordStore(String name, int partitionId)
protected CacheOperationProvider	createOperationProvider(String nameWithPrefix, InMemoryFormat inMemoryFormat)
CacheWanEventPublisher	getCacheWanEventPublisher()
boolean	isWanReplicationEnabled(String cacheName)
protected CachePartitionSegment	newPartitionSegment(int partitionId)
Operation	prepareReplicationOperation(PartitionReplicationEvent event) Returns an operation to replicate service data and/or state for a specific partition replica on another cluster member.
String	toString()

Methods inherited from class com.hazelcast.cache.impl.AbstractCacheService

addCacheResource, addInvalidationListener, beforeMigration, cacheEntryListenerDeregistered, cacheEntryListenerRegistered, checkCacheConfig, checkCacheSimpleConfig, closeSegments, commitMigration, createCacheStatIfAbsent, createDistributedObject, deleteCache, deleteCacheConfig, deleteCacheStat, deregisterAllListener, deregisterListener, destroyDistributedObject, destroySegments, dispatchEvent, findCacheConfig, getCacheConfig, getCacheConfigs, getCacheContext, getCacheOperationProvider, getNodeEngine, getOrCreateCacheContext, getOrCreateRecordStore, getPostJoinOperation, getQuorumName, getRecordStore, getSegment, getStatistics, init, isNativeInMemoryFormatSupported, onPartitionLost, postInit, prepareMergeRunnable, publishCachePartitionLostEvent, publishEvent, publishEvent, putCacheConfigIfAbsent, registerListener, registerListener, registerListenerInternal, reset, rollbackMigration, sendInvalidationEvent, setManagementEnabled, setStatisticsEnabled, shutdown, toData, toObject

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheService

public CacheService()

Method Detail

newPartitionSegment

protected CachePartitionSegment newPartitionSegment(int partitionId)

Specified by:

newPartitionSegment in class AbstractCacheService

createNewRecordStore

protected ICacheRecordStore createNewRecordStore(String name,
                                                 int partitionId)

Specified by:

createNewRecordStore in class AbstractCacheService

createOperationProvider

protected CacheOperationProvider createOperationProvider(String nameWithPrefix,
                                                         InMemoryFormat inMemoryFormat)

Specified by:

createOperationProvider in class AbstractCacheService

prepareReplicationOperation

public Operation prepareReplicationOperation(PartitionReplicationEvent event)

Description copied from interface: MigrationAwareService

Returns an operation to replicate service data and/or state for a specific partition replica on another cluster member.

This method will be called on source member whenever partitioning system requires to copy/replicate a partition replica. Returned operation will be executed on destination member. If operation fails by throwing exception, migration process will fail and will be rolled back.

Returning null is allowed and means service does not have anything to replicate.

Parameters:

event - replication

Returns:

replication operation or null if nothing will be replicated

toString

public String toString()

Overrides:

toString in class Object

isWanReplicationEnabled

public boolean isWanReplicationEnabled(String cacheName)

getCacheWanEventPublisher

public CacheWanEventPublisher getCacheWanEventPublisher()