com.hazelcast.map.impl.querycache.subscriber

Class AbstractQueryCacheEndToEndConstructor

java.lang.Object

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

All Implemented Interfaces:

QueryCacheEndToEndConstructor, ConstructorFunction<String,InternalQueryCache>

Direct Known Subclasses:

ClientQueryCacheEndToEndConstructor, NodeQueryCacheEndToEndConstructor

public abstract class AbstractQueryCacheEndToEndConstructor
extends Object
implements QueryCacheEndToEndConstructor

Provides generic functionality for QueryCacheEndToEndConstructor implementations.

See Also:

QueryCacheEndToEndConstructor

Field Summary

Fields

Modifier and Type	Field and Description
protected QueryCacheContext	context
protected boolean	includeValue
protected ILogger	logger
protected String	mapName
protected static int	OPERATION_WAIT_TIMEOUT_MINUTES
protected Predicate	predicate
protected String	publisherListenerId
protected InternalQueryCache	queryCache
protected QueryCacheRequest	request
protected SubscriberContext	subscriberContext

Constructor Summary

Constructors

Constructor and Description
AbstractQueryCacheEndToEndConstructor(QueryCacheRequest request)

Method Summary

Modifier and Type	Method and Description
InternalQueryCache	createNew(String arg) Here order of method calls should not change.
void	createSubscriberAccumulator(AccumulatorInfo info) Creates a new SubscriberAccumulator
String	getCacheName()
protected QueryCacheConfig	initQueryCacheConfig(QueryCacheRequest request)
protected Object	toObject(Object data)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.map.impl.querycache.subscriber.QueryCacheEndToEndConstructor

createPublisherAccumulator

Field Detail

OPERATION_WAIT_TIMEOUT_MINUTES

protected static final int OPERATION_WAIT_TIMEOUT_MINUTES

See Also:

Constant Field Values

mapName

protected final String mapName

request

protected final QueryCacheRequest request

context

protected final QueryCacheContext context

subscriberContext

protected final SubscriberContext subscriberContext

logger

protected final ILogger logger

predicate

protected Predicate predicate

includeValue

protected boolean includeValue

queryCache

protected InternalQueryCache queryCache

publisherListenerId

protected String publisherListenerId

Constructor Detail

AbstractQueryCacheEndToEndConstructor

public AbstractQueryCacheEndToEndConstructor(QueryCacheRequest request)

Method Detail

createSubscriberAccumulator

public final void createSubscriberAccumulator(AccumulatorInfo info)

Description copied from interface: QueryCacheEndToEndConstructor

Creates a new SubscriberAccumulator

Specified by:

createSubscriberAccumulator in interface QueryCacheEndToEndConstructor

Parameters:

info - AccumulatorInfo for the SubscriberAccumulator

createNew

public final InternalQueryCache createNew(String arg)

Here order of method calls should not change.

Specified by:

createNew in interface ConstructorFunction<String,InternalQueryCache>

Parameters:

arg - construction argument

Returns:

a new instance of an object

getCacheName

public String getCacheName()

toObject

protected Object toObject(Object data)

initQueryCacheConfig

protected QueryCacheConfig initQueryCacheConfig(QueryCacheRequest request)