public class ContinuousQueryDefinition extends Object implements InitializingBean
CqQuery
.InitializingBean
Constructor and Description |
---|
ContinuousQueryDefinition(String query,
ContinuousQueryListener listener) |
ContinuousQueryDefinition(String query,
ContinuousQueryListener listener,
boolean durable) |
ContinuousQueryDefinition(String name,
String query,
ContinuousQueryListener listener) |
ContinuousQueryDefinition(String name,
String query,
ContinuousQueryListener listener,
boolean durable) |
Modifier and Type | Method and 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.
|
org.apache.geode.cache.query.CqAttributes |
toCqAttributes(Function<ContinuousQueryListener,org.apache.geode.cache.query.CqListener> listenerFunction) |
public ContinuousQueryDefinition(String query, ContinuousQueryListener listener)
public ContinuousQueryDefinition(String query, ContinuousQueryListener listener, boolean durable)
public ContinuousQueryDefinition(String name, String query, ContinuousQueryListener listener)
public ContinuousQueryDefinition(String name, String query, ContinuousQueryListener listener, boolean durable)
public static ContinuousQueryDefinition from(Object delegate, Method method)
public boolean isDurable()
public boolean isNamed()
getName()
public ContinuousQueryListener getListener()
ContinuousQueryListener
that will process/handle CQ event notifications.public String getQuery()
query
executed by the CQ.query
executed by the CQ.public void afterPropertiesSet()
afterPropertiesSet
in interface InitializingBean
public org.apache.geode.cache.query.CqAttributes toCqAttributes(Function<ContinuousQueryListener,org.apache.geode.cache.query.CqListener> listenerFunction)
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.