public class NodeSubscriberContextSupport extends Object implements SubscriberContextSupport
SubscriberContextSupport
implementation for node side.SubscriberContextSupport
Constructor and Description |
---|
NodeSubscriberContextSupport(InternalSerializationService serializationService) |
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.
|
public NodeSubscriberContextSupport(InternalSerializationService serializationService)
public Object createRecoveryOperation(String mapName, String cacheId, long sequence, int partitionId)
SubscriberContextSupport
createRecoveryOperation
in interface SubscriberContextSupport
mapName
- map namecacheId
- ID of cachesequence
- sequence to be setpartitionId
- partitions ID of broken sequenceQueryCache.tryRecover()
public Boolean resolveResponseForRecoveryOperation(Object response)
SubscriberContextSupport
resolveResponseForRecoveryOperation
in interface SubscriberContextSupport
response
- clientMessage or datapublic Object createDestroyQueryCacheOperation(String mapName, String cacheId)
SubscriberContextSupport
createDestroyQueryCacheOperation
in interface SubscriberContextSupport
mapName
- map namecacheId
- ID of cacheQueryCache.tryRecover()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.