org.infinispan.client.hotrod.event

Class ContinuousQueryImpl<K,V>

java.lang.Object

org.infinispan.client.hotrod.event.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 cache.

This class is not threadsafe.

Since:

8.2

Author:

anistor@redhat.com

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
<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()
void	removeAllListeners()
void	removeContinuousQueryListener(ContinuousQueryListener<K,?> listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

ContinuousQueryImpl

public ContinuousQueryImpl(RemoteCache<K,V> cache)

Method Detail

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)

Specified by:

removeContinuousQueryListener in interface ContinuousQuery<K,V>

getListeners

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

Specified by:

getListeners in interface ContinuousQuery<K,V>

removeAllListeners

public void removeAllListeners()

Specified by:

removeAllListeners in interface ContinuousQuery<K,V>