com.hazelcast.cache.impl.event

Interface CacheWanEventPublisher

public interface CacheWanEventPublisher

This interface provides methods to publish wan replication events from cache operations.

Methods of this class should be called from within the partition thread to keep event order for keys belonging to a single partition.

Method Summary

Modifier and Type	Method and Description
void	publishWanReplicationRemove(String cacheNameWithPrefix, Data key) This method will create a wrapper object using the given CacheEntryView and place it to wan replication queues.
void	publishWanReplicationRemoveBackup(String cacheNameWithPrefix, Data key) Backup operations of operations that call this#publishWanReplicationRemove(String, Data) should call this method to provide wan event backups
void	publishWanReplicationUpdate(String cacheNameWithPrefix, CacheEntryView<Data,Data> entryView) This method will create a wrapper object using the given CacheEntryView and place it to wan replication queues.
void	publishWanReplicationUpdateBackup(String cacheNameWithPrefix, CacheEntryView<Data,Data> entryView) Backup operations of operations that call this#publishWanReplicationUpdate(String, CacheEntryView) should call this method to provide wan event backups

Method Detail

publishWanReplicationUpdate

void publishWanReplicationUpdate(String cacheNameWithPrefix,
                                 CacheEntryView<Data,Data> entryView)

This method will create a wrapper object using the given CacheEntryView and place it to wan replication queues.

Updating cache operations should call this method in their Operation.afterRun() method.

Parameters:

cacheNameWithPrefix - the full name of the ICache, including the manager scope prefix

entryView - the updated cache entry

See Also:

CachePutOperation, CacheGetAndReplaceOperation

publishWanReplicationRemove

void publishWanReplicationRemove(String cacheNameWithPrefix,
                                 Data key)

This method will create a wrapper object using the given CacheEntryView and place it to wan replication queues.

Cache operations which removes data from cache should call this method in their Operation.afterRun() method.

Parameters:

cacheNameWithPrefix - the full name of the ICache, including the manager scope prefix

key - the key of the removed entry

See Also:

CacheRemoveOperation

publishWanReplicationUpdateBackup

void publishWanReplicationUpdateBackup(String cacheNameWithPrefix,
                                       CacheEntryView<Data,Data> entryView)

Backup operations of operations that call this#publishWanReplicationUpdate(String, CacheEntryView) should call this method to provide wan event backups

Parameters:

cacheNameWithPrefix - the full name of the ICache, including the manager scope prefix

entryView - the updated cache entry

See Also:

CachePutBackupOperation

publishWanReplicationRemoveBackup

void publishWanReplicationRemoveBackup(String cacheNameWithPrefix,
                                       Data key)

Backup operations of operations that call this#publishWanReplicationRemove(String, Data) should call this method to provide wan event backups

Parameters:

cacheNameWithPrefix - the full name of the ICache, including the manager scope prefix

key - the key of the removed entry

See Also:

CacheRemoveBackupOperation