com.hazelcast.client.impl.querycache.subscriber

Class ClientSubscriberContextSupport

java.lang.Object

com.hazelcast.client.impl.querycache.subscriber.ClientSubscriberContextSupport

All Implemented Interfaces:

SubscriberContextSupport

public class ClientSubscriberContextSupport
extends Object
implements SubscriberContextSupport

SubscriberContextSupport implementation for client side.

See Also:

SubscriberContextSupport

Constructor Summary

Constructors

Constructor and Description
ClientSubscriberContextSupport()

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 object) Resolves response of recoveryOperation.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientSubscriberContextSupport

public ClientSubscriberContextSupport()

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

Description copied from interface: SubscriberContextSupport

Resolves response of recoveryOperation.

Specified by:

resolveResponseForRecoveryOperation in interface SubscriberContextSupport

Parameters:

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