public final class ContinuousQueryImpl<K,V> extends Object implements 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(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) |
public ContinuousQueryImpl(RemoteCache<K,V> cache)
public <C> void addContinuousQueryListener(Query query, ContinuousQueryListener<K,C> listener)
addContinuousQueryListener
in interface ContinuousQuery<K,V>
listener
- the continuous query listener instancequery
- the query to be used for determining the matching setpublic void removeContinuousQueryListener(ContinuousQueryListener<K,?> listener)
removeContinuousQueryListener
in interface ContinuousQuery<K,V>
public List<ContinuousQueryListener<K,?>> getListeners()
getListeners
in interface ContinuousQuery<K,V>
public void removeAllListeners()
removeAllListeners
in interface ContinuousQuery<K,V>
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.