Package org.springframework.data.gemfire.listener

Class ContinuousQueryDefinition

java.lang.Object

org.springframework.data.gemfire.listener.ContinuousQueryDefinition

All Implemented Interfaces:

InitializingBean

public class ContinuousQueryDefinition
extends Object
implements InitializingBean

Class type for defining a CqQuery.

Author:

Costin Leau, John Blum

See Also:

• InitializingBean

Constructor Summary

Constructors

Constructor	Description
ContinuousQueryDefinition(String name, String query, ContinuousQueryListener listener)
ContinuousQueryDefinition(String name, String query, ContinuousQueryListener listener, boolean durable)
ContinuousQueryDefinition(String query, ContinuousQueryListener listener)
ContinuousQueryDefinition(String query, ContinuousQueryListener listener, boolean durable)

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
static ContinuousQueryDefinition	from(Object delegate, Method method)
ContinuousQueryListener	getListener()	Returns a reference to the ContinuousQueryListener that will process/handle CQ event notifications.
String	getName()	Gets the name of the CQ.
String	getQuery()	Gets the query executed by the CQ.
boolean	isDurable()	Determines whether the CQ is durable.
boolean	isNamed()	Determines whether the CQ was named.
CqAttributes	toCqAttributes(Function<ContinuousQueryListener,CqListener> listenerFunction)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ContinuousQueryDefinition

public ContinuousQueryDefinition(String query,
 ContinuousQueryListener listener)

ContinuousQueryDefinition

public ContinuousQueryDefinition(String query,
 ContinuousQueryListener listener,
 boolean durable)

ContinuousQueryDefinition

public ContinuousQueryDefinition(String name,
 String query,
 ContinuousQueryListener listener)

ContinuousQueryDefinition

public ContinuousQueryDefinition(String name,
 String query,
 ContinuousQueryListener listener,
 boolean durable)

Method Details

from

public static ContinuousQueryDefinition from(Object delegate,
 Method method)

isDurable

public boolean isDurable()

Determines whether the CQ is durable.

Returns:

a boolean indicating if the CQ is durable.

isNamed

public boolean isNamed()

Determines whether the CQ was named.

Returns:

a boolean value indicating whether the CQ is named.

See Also:

• getName()

getListener

public ContinuousQueryListener getListener()

Returns a reference to the ContinuousQueryListener that will process/handle CQ event notifications.

Returns:

the CQ listener registered with the CQ to handle CQ events.

getName

public String getName()

Gets the name of the CQ.

Returns:

the name of the CQ.

getQuery

public String getQuery()

Gets the query executed by the CQ.

Returns:

the query executed by the CQ.

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

toCqAttributes

public CqAttributes toCqAttributes(Function<ContinuousQueryListener,CqListener> listenerFunction)