Class ContinuousQueryDefinition
java.lang.Object
org.springframework.data.gemfire.listener.ContinuousQueryDefinition
- All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean
public class ContinuousQueryDefinition
extends Object
implements org.springframework.beans.factory.InitializingBean
Class type for defining a
CqQuery
.- See Also:
-
InitializingBean
-
Constructor Summary
ConstructorDescriptionContinuousQueryDefinition
(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 TypeMethodDescriptionvoid
static ContinuousQueryDefinition
Returns a reference to theContinuousQueryListener
that will process/handle CQ event notifications.getName()
Gets thename
of the CQ.getQuery()
Gets thequery
executed by the CQ.boolean
Determines whether the CQ is durable.boolean
isNamed()
Determines whether the CQ was named.org.apache.geode.cache.query.CqAttributes
toCqAttributes
(Function<ContinuousQueryListener, org.apache.geode.cache.query.CqListener> listenerFunction)
-
Constructor Details
-
ContinuousQueryDefinition
-
ContinuousQueryDefinition
-
ContinuousQueryDefinition
-
ContinuousQueryDefinition
public ContinuousQueryDefinition(String name, String query, ContinuousQueryListener listener, boolean durable)
-
-
Method Details
-
from
-
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:
-
getListener
Returns a reference to theContinuousQueryListener
that will process/handle CQ event notifications.- Returns:
- the CQ listener registered with the CQ to handle CQ events.
-
getName
Gets thename
of the CQ.- Returns:
- the
name
of the CQ.
-
getQuery
Gets thequery
executed by the CQ.- Returns:
- the
query
executed by the CQ.
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSet
in interfaceorg.springframework.beans.factory.InitializingBean
-
toCqAttributes
public org.apache.geode.cache.query.CqAttributes toCqAttributes(Function<ContinuousQueryListener, org.apache.geode.cache.query.CqListener> listenerFunction)
-