com.hazelcast.map.impl.querycache.subscriber

Class NodeQueryCacheEndToEndConstructor

java.lang.Object

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

com.hazelcast.map.impl.querycache.subscriber.NodeQueryCacheEndToEndConstructor

All Implemented Interfaces:

QueryCacheEndToEndConstructor, ConstructorFunction<String,InternalQueryCache>

public class NodeQueryCacheEndToEndConstructor
extends AbstractQueryCacheEndToEndConstructor

Node-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
NodeQueryCacheEndToEndConstructor(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

NodeQueryCacheEndToEndConstructor

public NodeQueryCacheEndToEndConstructor(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