com.hazelcast.map.impl.querycache.subscriber

Class NodeSubscriberContextSupport

java.lang.Object

com.hazelcast.map.impl.querycache.subscriber.NodeSubscriberContextSupport

All Implemented Interfaces:

SubscriberContextSupport

public class NodeSubscriberContextSupport
extends Object
implements SubscriberContextSupport

SubscriberContextSupport implementation for node side.

See Also:

SubscriberContextSupport

Constructor Summary

Constructors

Constructor and Description
NodeSubscriberContextSupport(InternalSerializationService serializationService)

Method Summary

Modifier and Type	Method and Description
Object	createDestroyQueryCacheOperation(String mapName, String cacheName) Creates recovery operation for event loss cases.
Object	createRecoveryOperation(String mapName, String cacheName, long sequence, int partitionId) Creates recovery operation for event loss cases.
Boolean	resolveResponseForRecoveryOperation(Object response) Resolves response of recoveryOperation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NodeSubscriberContextSupport

public NodeSubscriberContextSupport(InternalSerializationService serializationService)

Method Detail

createRecoveryOperation

public Object createRecoveryOperation(String mapName,
                                      String cacheName,
                                      long sequence,
                                      int partitionId)

Description copied from interface: SubscriberContextSupport

Creates recovery operation for event loss cases.

Specified by:

createRecoveryOperation in interface SubscriberContextSupport

Parameters:

mapName - map name.

cacheName - cache name.

sequence - sequence to be set.

partitionId - partitions id of broken sequence

Returns:

operation or request according to context.

See Also:

QueryCache.tryRecover()

resolveResponseForRecoveryOperation

public Boolean resolveResponseForRecoveryOperation(Object response)

Description copied from interface: SubscriberContextSupport

Resolves response of recoveryOperation.

Specified by:

resolveResponseForRecoveryOperation in interface SubscriberContextSupport

Parameters:

response - clientMessage or data

Returns:

resolved response

createDestroyQueryCacheOperation

public Object createDestroyQueryCacheOperation(String mapName,
                                               String cacheName)

Description copied from interface: SubscriberContextSupport

Creates recovery operation for event loss cases.

Specified by:

createDestroyQueryCacheOperation in interface SubscriberContextSupport

Parameters:

mapName - map name.

cacheName - cache name.

Returns:

operation or request according to context.

See Also:

QueryCache.tryRecover()