Package org.infinispan.client.hotrod.event.impl

Class ContinuousQueryImpl<K,V>

java.lang.Object

org.infinispan.client.hotrod.event.impl.ContinuousQueryImpl<K,V>

All Implemented Interfaces:

ContinuousQuery<K,V>

public final class ContinuousQueryImpl<K,V>
extends Object
implements ContinuousQuery<K,V>

A container of continuous query listeners for a remote cache.

This class is not threadsafe.

Since:

8.2

Author:

anistor@redhat.com

Constructor Summary

Constructors

Constructor	Description
ContinuousQueryImpl(RemoteCache<K,V> cache)

Method Summary

Modifier and Type	Method	Description
<C> void	addContinuousQueryListener(String queryString, Map<String,Object> namedParameters, ContinuousQueryListener<K,C> listener)	Add a listener for a continuous query.
<C> void	addContinuousQueryListener(String queryString, ContinuousQueryListener<K,C> listener)	Add a listener for a continuous query.
<C> void	addContinuousQueryListener(Query<?> query, ContinuousQueryListener<K,C> listener)	Registers a continuous query listener that uses a query DSL based filter.
List<ContinuousQueryListener<K,?>>	getListeners()	Get the list of currently registered listeners.
void	removeAllListeners()	Unregisters all listeners.
void	removeContinuousQueryListener(ContinuousQueryListener<K,?> listener)	Remove a continuous query listener.

Methods inherited from class java.lang.Object

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

Constructor Details

ContinuousQueryImpl

public ContinuousQueryImpl(RemoteCache<K,V> cache)

Method Details

addContinuousQueryListener

public <C> void addContinuousQueryListener(String queryString,
 ContinuousQueryListener<K,C> listener)

Description copied from interface: ContinuousQuery

Add a listener for a continuous query.

Specified by:

addContinuousQueryListener in interface ContinuousQuery<K,V>

Parameters:

queryString - the query

listener - the listener

addContinuousQueryListener

public <C> void addContinuousQueryListener(String queryString,
 Map<String,Object> namedParameters,
 ContinuousQueryListener<K,C> listener)

Description copied from interface: ContinuousQuery

Add a listener for a continuous query.

Specified by:

addContinuousQueryListener in interface ContinuousQuery<K,V>

Parameters:

queryString - the query

namedParameters - the query parameters

listener - the listener

addContinuousQueryListener

public <C> void addContinuousQueryListener(Query<?> query,
 ContinuousQueryListener<K,C> listener)

Registers a continuous query listener that uses a query DSL based filter. The listener will receive notifications when a cache entry joins or leaves the matching set defined by the query.

Specified by:

addContinuousQueryListener in interface ContinuousQuery<K,V>

Parameters:

listener - the continuous query listener instance

query - the query to be used for determining the matching set

removeContinuousQueryListener

public void removeContinuousQueryListener(ContinuousQueryListener<K,?> listener)

Description copied from interface: ContinuousQuery

Remove a continuous query listener.

Specified by:

removeContinuousQueryListener in interface ContinuousQuery<K,V>

Parameters:

listener - the listener to remove

getListeners

public List<ContinuousQueryListener<K,?>> getListeners()

Description copied from interface: ContinuousQuery

Get the list of currently registered listeners.

Specified by:

getListeners in interface ContinuousQuery<K,V>

removeAllListeners

public void removeAllListeners()

Description copied from interface: ContinuousQuery

Unregisters all listeners.

Specified by:

removeAllListeners in interface ContinuousQuery<K,V>