com.hazelcast.map.impl.querycache.subscriber

Interface QueryCacheEndToEndConstructor

All Superinterfaces:

ConstructorFunction<String,InternalQueryCache>

All Known Implementing Classes:

AbstractQueryCacheEndToEndConstructor, ClientQueryCacheEndToEndConstructor, NodeQueryCacheEndToEndConstructor

public interface QueryCacheEndToEndConstructor
extends ConstructorFunction<String,InternalQueryCache>

Constructor which is used to construct all parts/sides of a QueryCache system on nodes or on clients. This constructor is called from subscriber-side and initiates the construction of whole underlying system which feeds the QueryCache.

When this constructor returns successfully, there should be a QueryCache instance ready to use.

See Also:

QueryCache

Method Summary

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

Methods inherited from interface com.hazelcast.util.ConstructorFunction

createNew

Method Detail

createSubscriberAccumulator

void createSubscriberAccumulator(AccumulatorInfo info)
                          throws Exception

Creates a new SubscriberAccumulator

Parameters:

info - AccumulatorInfo for the SubscriberAccumulator

Throws:

Exception - in case of any exceptional case.

createPublisherAccumulator

void createPublisherAccumulator(AccumulatorInfo info)
                         throws Exception

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