public interface SubscriberContextSupport
SubscriberContext
.Modifier and Type | Method and Description |
---|---|
Object |
createDestroyQueryCacheOperation(String mapName,
String cacheId)
Creates recovery operation for event loss cases.
|
Object |
createRecoveryOperation(String mapName,
String cacheId,
long sequence,
int partitionId)
Creates recovery operation for event loss cases.
|
Boolean |
resolveResponseForRecoveryOperation(Object response)
Resolves response of recoveryOperation.
|
Object createRecoveryOperation(String mapName, String cacheId, long sequence, int partitionId)
mapName
- map namecacheId
- ID of cachesequence
- sequence to be setpartitionId
- partitions ID of broken sequenceQueryCache.tryRecover()
Boolean resolveResponseForRecoveryOperation(Object response)
response
- clientMessage or dataObject createDestroyQueryCacheOperation(String mapName, String cacheId)
mapName
- map namecacheId
- ID of cacheQueryCache.tryRecover()
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.