public interface CacheWanEventPublisher
Methods of this class should be called from within the partition thread to keep event order for keys belonging to a single partition.
Modifier and Type | Method and Description |
---|---|
void |
publishWanRemove(String cacheNameWithPrefix,
Data key)
This method will create a wrapper object using the given
CacheEntryView
and place it to wan replication queues. |
void |
publishWanUpdate(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 publishWanUpdate(String cacheNameWithPrefix, CacheEntryView<Data,Data> entryView)
CacheEntryView
and place it to wan replication queues.
Updating cache operations should call this method in their Operation.afterRun()
method.
cacheNameWithPrefix
- the full name of the ICache
, including the manager scope prefixentryView
- the updated cache entryCachePutOperation
,
CacheGetAndReplaceOperation
void publishWanRemove(String cacheNameWithPrefix, Data key)
CacheEntryView
and place it to wan replication queues.
Cache operations which removes data from cache should call this method in their
Operation.afterRun()
method.
cacheNameWithPrefix
- the full name of the ICache
, including the manager scope prefixkey
- the key of the removed entryCacheRemoveOperation
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.