com.hazelcast.map.impl.querycache.subscriber

Interface SubscriberContextSupport

All Known Implementing Classes:

ClientSubscriberContextSupport, NodeSubscriberContextSupport

public interface SubscriberContextSupport

Contains various helpers for SubscriberContext.

Method Summary

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.

Method Detail

createRecoveryOperation

Object createRecoveryOperation(String mapName,
                               String cacheId,
                               long sequence,
                               int partitionId)

Creates recovery operation for event loss cases.

Parameters:

mapName - map name

cacheId - ID of cache

sequence - sequence to be set

partitionId - partitions ID of broken sequence

Returns:

operation or request according to context

See Also:

QueryCache.tryRecover()

resolveResponseForRecoveryOperation

Boolean resolveResponseForRecoveryOperation(Object response)

Resolves response of recoveryOperation.

Parameters:

response - clientMessage or data

Returns:

resolved response

createDestroyQueryCacheOperation

Object createDestroyQueryCacheOperation(String mapName,
                                        String cacheId)

Creates recovery operation for event loss cases.

Parameters:

mapName - map name

cacheId - ID of cache

Returns:

operation or request according to context

See Also:

QueryCache.tryRecover()