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:

org.infinispan.query.api.continuous.ContinuousQuery<K,V>

public final class ContinuousQueryImpl<K,V>
extends Object
implements org.infinispan.query.api.continuous.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 and Description
ContinuousQueryImpl(RemoteCache<K,V> cache)

Method Summary

Modifier and Type	Method and Description
<C> void	addContinuousQueryListener(org.infinispan.query.dsl.Query<?> query, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener) Registers a continuous query listener that uses a query DSL based filter.
<C> void	addContinuousQueryListener(String queryString, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
<C> void	addContinuousQueryListener(String queryString, Map<String,Object> namedParameters, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
List<org.infinispan.query.api.continuous.ContinuousQueryListener<K,?>>	getListeners()
void	removeAllListeners()
void	removeContinuousQueryListener(org.infinispan.query.api.continuous.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(String queryString,
                                           org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)

Specified by:

addContinuousQueryListener in interface org.infinispan.query.api.continuous.ContinuousQuery<K,V>

addContinuousQueryListener

public <C> void addContinuousQueryListener(String queryString,
                                           Map<String,Object> namedParameters,
                                           org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)

Specified by:

addContinuousQueryListener in interface org.infinispan.query.api.continuous.ContinuousQuery<K,V>

addContinuousQueryListener

public <C> void addContinuousQueryListener(org.infinispan.query.dsl.Query<?> query,
                                           org.infinispan.query.api.continuous.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 org.infinispan.query.api.continuous.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(org.infinispan.query.api.continuous.ContinuousQueryListener<K,?> listener)

Specified by:

removeContinuousQueryListener in interface org.infinispan.query.api.continuous.ContinuousQuery<K,V>

getListeners

public List<org.infinispan.query.api.continuous.ContinuousQueryListener<K,?>> getListeners()

Specified by:

getListeners in interface org.infinispan.query.api.continuous.ContinuousQuery<K,V>

removeAllListeners

public void removeAllListeners()

Specified by:

removeAllListeners in interface org.infinispan.query.api.continuous.ContinuousQuery<K,V>