Package org.infinispan.query.api.continuous

Interface ContinuousQuery<K,V>

public interface ContinuousQuery<K,V>

A container of continuous query listeners for a cache.

Implementations are not expected to be threadsafe.

Since:

8.2

Author:

anistor@redhat.com

Method Summary

Modifier and Type	Method	Description
<C> void	addContinuousQueryListener(String queryString, Map<String,Object> namedParameters, ContinuousQueryListener<K,C> listener)	Add a listener for a continuous query.
<C> void	addContinuousQueryListener(String queryString, ContinuousQueryListener<K,C> listener)	Add a listener for a continuous query.
<C> void	addContinuousQueryListener(Query<?> query, ContinuousQueryListener<K,C> listener)	Add a listener for a continuous query.
List<ContinuousQueryListener<K,?>>	getListeners()	Get the list of currently registered listeners.
void	removeAllListeners()	Unregisters all listeners.
void	removeContinuousQueryListener(ContinuousQueryListener<K,?> listener)	Remove a continuous query listener.

Method Detail

addContinuousQueryListener

<C> void addContinuousQueryListener(String queryString,
                                    ContinuousQueryListener<K,C> listener)

Add a listener for a continuous query.

Parameters:

queryString - the query

listener - the listener

addContinuousQueryListener

<C> void addContinuousQueryListener(String queryString,
                                    Map<String,Object> namedParameters,
                                    ContinuousQueryListener<K,C> listener)

Add a listener for a continuous query.

Parameters:

queryString - the query

namedParameters - the query parameters

listener - the listener

addContinuousQueryListener

<C> void addContinuousQueryListener(Query<?> query,
                                    ContinuousQueryListener<K,C> listener)

Add a listener for a continuous query.

Parameters:

query - the query object

listener - the listener

removeContinuousQueryListener

void removeContinuousQueryListener(ContinuousQueryListener<K,?> listener)

Remove a continuous query listener.

Parameters:

listener - the listener to remove

getListeners

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

Get the list of currently registered listeners.

removeAllListeners

void removeAllListeners()

Unregisters all listeners.