public final class ContinuousQueryImpl<K,V> extends Object implements org.infinispan.query.api.continuous.ContinuousQuery<K,V>
This class is not threadsafe.
Constructor and Description |
---|
ContinuousQueryImpl(RemoteCache<K,V> cache) |
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)
Add a listener for a continuous query.
|
<C> void |
addContinuousQueryListener(String queryString,
Map<String,Object> namedParameters,
org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
Add a listener for a continuous query.
|
List<org.infinispan.query.api.continuous.ContinuousQueryListener<K,?>> |
getListeners()
Get the list of currently registered listeners.
|
void |
removeAllListeners()
Unregisters all listeners.
|
void |
removeContinuousQueryListener(org.infinispan.query.api.continuous.ContinuousQueryListener<K,?> listener)
Remove a continuous query listener.
|
public ContinuousQueryImpl(RemoteCache<K,V> cache)
public <C> void addContinuousQueryListener(String queryString, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
org.infinispan.query.api.continuous.ContinuousQuery
public <C> void addContinuousQueryListener(String queryString, Map<String,Object> namedParameters, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
org.infinispan.query.api.continuous.ContinuousQuery
public <C> void addContinuousQueryListener(org.infinispan.query.dsl.Query query, org.infinispan.query.api.continuous.ContinuousQueryListener<K,C> listener)
public void removeContinuousQueryListener(org.infinispan.query.api.continuous.ContinuousQueryListener<K,?> listener)
org.infinispan.query.api.continuous.ContinuousQuery
public List<org.infinispan.query.api.continuous.ContinuousQueryListener<K,?>> getListeners()
org.infinispan.query.api.continuous.ContinuousQuery
Copyright © 2019 JBoss, a division of Red Hat. All rights reserved.