Package com.tangosol.coherence.config.scheme

Class ContinuousQueryCacheScheme

java.lang.Object

com.tangosol.coherence.config.scheme.AbstractScheme

com.tangosol.coherence.config.scheme.AbstractServiceScheme

com.tangosol.coherence.config.scheme.AbstractCachingScheme

com.tangosol.coherence.config.scheme.AbstractLocalCachingScheme

com.tangosol.coherence.config.scheme.ContinuousQueryCacheScheme

All Implemented Interfaces:

BackingMapManagerBuilder, BuilderCustomization, MapBuilder, NamedCacheBuilder, ServiceBuilder, CachingScheme, ObservableCachingScheme, Scheme, ServiceScheme

public class ContinuousQueryCacheScheme
extends AbstractLocalCachingScheme

This scheme is internally used to provide the ParameterizedBuilder that constructs the view-filter for the ViewScheme.

Since:

12.2.1.4

Author:

rlubke

Nested Class Summary

Nested classes/interfaces inherited from interface com.tangosol.coherence.config.builder.MapBuilder

MapBuilder.Dependencies

Field Summary

Fields

Modifier and Type	Field	Description
protected long	m_cReconnectMillis	The reconnect interval to pass to the ContinuousQueryCache.
protected boolean	m_fReadOnly	The read-only flag to pass to the ContinuousQueryCache.

Fields inherited from class com.tangosol.coherence.config.scheme.AbstractServiceScheme

m_serviceDependencies

Fields inherited from interface com.tangosol.coherence.config.scheme.ServiceScheme

DELIM_APPLICATION_SCOPE, DELIM_DOMAIN_PARTITION

Constructor Summary

Constructors

Constructor	Description
ContinuousQueryCacheScheme()

Method Summary

Modifier and Type	Method	Description
ParameterizedBuilder<Filter>	getFilterBuilder()	Return the ParameterizedBuilder used to construct the Filter to be used by the ContinuousQueryCache.
long	getReconnectInterval()	See ContinuousQueryCache.getReconnectInterval().
ParameterizedBuilder<ValueExtractor>	getTransformerBuilder()	Return the ParameterizedBuilder used to construct the ValueExtractor to be used as a transformer by the ContinuousQueryCache.
boolean	isReadOnly()	See ContinuousQueryCache.isReadOnly().
void	setFilterBuilder(ParameterizedBuilder<Filter> filterBuilder)	Set the ParameterizedBuilder used to construct the Filter to be used by the ContinuousQueryCache.
void	setReadOnly(boolean fReadOnly)	See ContinuousQueryCache.setReadOnly(boolean).
void	setReconnectInterval(long ldtReconnectInterval)	See ContinuousQueryCache.setReconnectInterval(long).
void	setTransformerBuilder(ParameterizedBuilder<ValueExtractor> transformerBuilder)	Set the ParameterizedBuilder used to construct the ValueExtractor to be used as a transformer by the ContinuousQueryCache.

Methods inherited from class com.tangosol.coherence.config.scheme.AbstractLocalCachingScheme

getCustomBuilder, getEventInterceptorBuilders, getServiceType, isRunningClusterNeeded, setCustomBuilder

Methods inherited from class com.tangosol.coherence.config.scheme.AbstractCachingScheme

establishMapListeners, getDefaultParameterResolver, getListenerBuilder, realizeBackingMapManager, realizeCache, realizeMap, setListenerBuilder, validate

Methods inherited from class com.tangosol.coherence.config.scheme.AbstractServiceScheme

ensureService, getDefaultServiceName, getScopedServiceName, getScopeName, getServiceBuilder, getServiceDependencies, getServiceName, getXml, injectScopeNameIntoService, isAutoStart, realizeService, setAutoStart, setScopeName, setServiceDependencies, setServiceName, setXml

Methods inherited from class com.tangosol.coherence.config.scheme.AbstractScheme

getSchemeName, isAnonymous, setSchemeName, validate

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tangosol.coherence.config.scheme.Scheme

getSchemeName, isAnonymous

Methods inherited from interface com.tangosol.coherence.config.scheme.ServiceScheme

getNamedCollectionBuilder, getScopedServiceName, getScopedServiceNameForProperty, getServiceBuilder, getServiceName, isAutoStart

Field Details

m_cReconnectMillis

protected long m_cReconnectMillis

The reconnect interval to pass to the ContinuousQueryCache.

m_fReadOnly

protected boolean m_fReadOnly

The read-only flag to pass to the ContinuousQueryCache.

Constructor Details

ContinuousQueryCacheScheme

public ContinuousQueryCacheScheme()

Method Details

setFilterBuilder

@Injectable("view-filter")
public void setFilterBuilder(ParameterizedBuilder<Filter> filterBuilder)

Set the ParameterizedBuilder used to construct the Filter to be used by the ContinuousQueryCache.

Parameters:

filterBuilder - the ParameterizedBuilder used to construct the ValueExtractor to be used as a transformer by the ContinuousQueryCache

getFilterBuilder

public ParameterizedBuilder<Filter> getFilterBuilder()

Return the ParameterizedBuilder used to construct the Filter to be used by the ContinuousQueryCache.

Returns:

the ParameterizedBuilder used to construct the Filter to be used by the ContinuousQueryCache

setTransformerBuilder

@Injectable("transformer")
public void setTransformerBuilder(ParameterizedBuilder<ValueExtractor> transformerBuilder)

Set the ParameterizedBuilder used to construct the ValueExtractor to be used as a transformer by the ContinuousQueryCache.

Parameters:

transformerBuilder - the ParameterizedBuilder used to construct the ValueExtractor to be used as a transformer by the ContinuousQueryCache

getTransformerBuilder

public ParameterizedBuilder<ValueExtractor> getTransformerBuilder()

Return the ParameterizedBuilder used to construct the ValueExtractor to be used as a transformer by the ContinuousQueryCache.

Returns:

the ParameterizedBuilder used to construct the ValueExtractor to be used as a transformer by the ContinuousQueryCache.

setReconnectInterval

@Injectable("reconnect-interval")
public void setReconnectInterval(long ldtReconnectInterval)

See ContinuousQueryCache.setReconnectInterval(long).

Parameters:

ldtReconnectInterval - reconnect interval in milliseconds

getReconnectInterval

public long getReconnectInterval()

See ContinuousQueryCache.getReconnectInterval().

Returns:

reconnect interval in milliseconds

setReadOnly

@Injectable("read-only")
public void setReadOnly(boolean fReadOnly)

See ContinuousQueryCache.setReadOnly(boolean).

Parameters:

fReadOnly - pass true to prohibit clients from making modifications to this cache

isReadOnly

public boolean isReadOnly()

See ContinuousQueryCache.isReadOnly().

Returns:

true if this ContinuousQueryCache has been configured as read-only