com.hazelcast.client.impl.querycache.subscriber

Class ClientQueryCacheEndToEndConstructor

java.lang.Object

com.hazelcast.map.impl.querycache.subscriber.AbstractQueryCacheEndToEndConstructor

com.hazelcast.client.impl.querycache.subscriber.ClientQueryCacheEndToEndConstructor

All Implemented Interfaces:

QueryCacheEndToEndConstructor, ConstructorFunction<String,InternalQueryCache>

public class ClientQueryCacheEndToEndConstructor
extends AbstractQueryCacheEndToEndConstructor

Client-side implementation of QueryCacheEndToEndConstructor.

See Also:

QueryCacheEndToEndConstructor

Field Summary

Fields inherited from class com.hazelcast.map.impl.querycache.subscriber.AbstractQueryCacheEndToEndConstructor

context, includeValue, logger, mapName, OPERATION_WAIT_TIMEOUT_MINUTES, predicate, publisherListenerId, queryCache, request, subscriberContext

Constructor Summary

Constructors

Constructor and Description
ClientQueryCacheEndToEndConstructor(QueryCacheRequest request)

Method Summary

Modifier and Type	Method and Description
void	createPublisherAccumulator(AccumulatorInfo info) Creates a new publisher-accumulator according to AccumulatorInfo.

Methods inherited from class com.hazelcast.map.impl.querycache.subscriber.AbstractQueryCacheEndToEndConstructor

createNew, createSubscriberAccumulator, getCacheName, initQueryCacheConfig, toObject

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientQueryCacheEndToEndConstructor

public ClientQueryCacheEndToEndConstructor(QueryCacheRequest request)

Method Detail

createPublisherAccumulator

public void createPublisherAccumulator(AccumulatorInfo info)
                                throws Exception

Description copied from interface: QueryCacheEndToEndConstructor

Creates a new publisher-accumulator according to AccumulatorInfo. This accumulator will be used to feed the SubscriberAccumulator.

Parameters:

info - AccumulatorInfo for the publisher-accumulator

Throws:

Exception - in case of any exceptional case.

See Also:

NonStopPublisherAccumulator, BatchPublisherAccumulator, CoalescingPublisherAccumulator