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()