com.tangosol.coherence.config.scheme

Class ContinuousQueryCacheScheme

java.lang.Object

com.tangosol.coherence.config.scheme.AbstractScheme

com.tangosol.coherence.config.scheme.AbstractServiceScheme<D>

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 and 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 and Description
ContinuousQueryCacheScheme()

Method Summary

Modifier and Type	Method and 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

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.ServiceScheme

getScopedServiceName, getServiceBuilder, getServiceName, isAutoStart

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

getSchemeName, isAnonymous

Field Detail

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 Detail

ContinuousQueryCacheScheme

public ContinuousQueryCacheScheme()

Method Detail

setFilterBuilder

@Injectable(value="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(value="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(value="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(value="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