Class ContinuousQueryImpl<K,V>
- java.lang.Object
-
- org.infinispan.client.hotrod.event.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 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <C> void
addContinuousQueryListener(String queryString, Map<String,Object> namedParameters, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
<C> void
addContinuousQueryListener(String queryString, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
<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.List<org.infinispan.query.api.continuous.ContinuousQueryListener<K,?>>
getListeners()
void
removeAllListeners()
void
removeContinuousQueryListener(org.infinispan.query.api.continuous.ContinuousQueryListener<K,?> listener)
-
-
-
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)
-
addContinuousQueryListener
public <C> void addContinuousQueryListener(String queryString, Map<String,Object> namedParameters, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
-
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.
-
removeContinuousQueryListener
public void removeContinuousQueryListener(org.infinispan.query.api.continuous.ContinuousQueryListener<K,?> listener)
-
getListeners
public List<org.infinispan.query.api.continuous.ContinuousQueryListener<K,?>> getListeners()
-
-