Package org.infinispan.query.continuous.impl

Class IckleContinuousQueryCacheEventFilterConverter<K,V,C>

java.lang.Object

org.infinispan.notifications.cachelistener.filter.AbstractCacheEventFilterConverter<K,V,C>

org.infinispan.query.continuous.impl.IckleContinuousQueryCacheEventFilterConverter<K,V,C>

All Implemented Interfaces:

CacheEventConverter<K,V,C>, CacheEventFilter<K,V>, CacheEventFilterConverter<K,V,C>, IndexedFilter<K,V,C>

public class IckleContinuousQueryCacheEventFilterConverter<K,V,C>
extends AbstractCacheEventFilterConverter<K,V,C>
implements IndexedFilter<K,V,C>

Since:

8.0

Author:

anistor@redhat.com

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	IckleContinuousQueryCacheEventFilterConverter.Externalizer

Field Summary

Fields

Modifier and Type	Field	Description
protected Matcher	matcher	The Matcher, acquired via dependency injection.
protected Class<? extends Matcher>	matcherImplClass	The implementation class of the Matcher component to lookup and use.
protected Map<String,Object>	namedParameters
protected ObjectFilter	objectFilter	The ObjectFilter is created lazily.
protected QueryCache	queryCache	Optional cache for query objects.
protected String	queryString	The Ickle query to execute.

Constructor Summary

Constructors

Constructor	Description
IckleContinuousQueryCacheEventFilterConverter(String queryString, Map<String,Object> namedParameters, Class<? extends Matcher> matcherImplClass)

Method Summary

Modifier and Type	Method	Description
C	filterAndConvert(K key, V oldValue, Metadata oldMetadata, V newValue, Metadata newMetadata, EventType eventType)	Will both filter the entry and if passed subsequently convert the value to a new value.
Matcher	getMatcher()
Map<String,Object>	getNamedParameters()
protected ObjectFilter	getObjectFilter()
String	getQueryString()
protected void	injectDependencies(Cache cache)	Acquires a Matcher instance from the ComponentRegistry of the given Cache object.
String	toString()

Methods inherited from class org.infinispan.notifications.cachelistener.filter.AbstractCacheEventFilterConverter

accept, convert

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.notifications.cachelistener.filter.CacheEventConverter

convert, useRequestFormat

Methods inherited from interface org.infinispan.notifications.cachelistener.filter.CacheEventFilter

accept

Methods inherited from interface org.infinispan.notifications.cachelistener.filter.CacheEventFilterConverter

format

Field Detail

queryString

protected final String queryString

The Ickle query to execute.

namedParameters

protected final Map<String,Object> namedParameters

matcherImplClass

protected Class<? extends Matcher> matcherImplClass

The implementation class of the Matcher component to lookup and use.

queryCache

protected QueryCache queryCache

Optional cache for query objects.

matcher

protected Matcher matcher

The Matcher, acquired via dependency injection.

objectFilter

protected ObjectFilter objectFilter

The ObjectFilter is created lazily.

Constructor Detail

IckleContinuousQueryCacheEventFilterConverter

public IckleContinuousQueryCacheEventFilterConverter(String queryString,
                                                     Map<String,Object> namedParameters,
                                                     Class<? extends Matcher> matcherImplClass)

Method Detail

getMatcher

public Matcher getMatcher()

getQueryString

public String getQueryString()

getNamedParameters

public Map<String,Object> getNamedParameters()

injectDependencies

protected void injectDependencies(Cache cache)

Acquires a Matcher instance from the ComponentRegistry of the given Cache object.

getObjectFilter

protected ObjectFilter getObjectFilter()

filterAndConvert

public C filterAndConvert(K key,
                          V oldValue,
                          Metadata oldMetadata,
                          V newValue,
                          Metadata newMetadata,
                          EventType eventType)

Description copied from interface: CacheEventFilterConverter

Will both filter the entry and if passed subsequently convert the value to a new value. A returned value of null will symbolize the value not passing the filter, so ensure your conversion will not return null if you want this entry to be returned.

Specified by:

filterAndConvert in interface CacheEventFilterConverter<K,V,C>

Parameters:

key - The key for the entry that was changed for the event

oldValue - The previous value before the event takes place

oldMetadata - The old value before the event takes place

newValue - The new value for the entry after the event takes place

newMetadata - The new metadata for the entry after the event takes place

eventType - The type of event that is being raised

Returns:

A non null value converted value when it also passes the filter or null for when it doesn't pass the filter

toString

public String toString()

Overrides:

toString in class Object