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 within the partition thread to wan keep event order.

Method Summary

Methods

Modifier and Type	Method and Description
void	publishWanReplicationRemove(String cacheName, Data key) This method will create a wrapper object using the given CacheEntryView and place it to wan replication queues.
void	publishWanReplicationRemoveBackup(String cacheName, Data key) Backup operations of operations that call this#publishWanReplicationRemove(String, Data) should call this method to provide wan event backups
void	publishWanReplicationUpdate(String cacheName, 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 cacheName, 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 cacheName,
                               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 AbstractOperation.afterRun() method.

See Also:

CachePutOperation, CacheGetAndReplaceOperation

publishWanReplicationRemove

void publishWanReplicationRemove(String cacheName,
                               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 AbstractOperation.afterRun() method.

See Also:

CacheRemoveOperation

publishWanReplicationUpdateBackup

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

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

See Also:

CachePutBackupOperation

publishWanReplicationRemoveBackup

void publishWanReplicationRemoveBackup(String cacheName,
                                     Data key)

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

See Also:

CacheRemoveBackupOperation