Package org.springframework.data.gemfire.config.annotation

Class ContinuousQueryConfiguration

java.lang.Object

org.springframework.data.gemfire.config.annotation.support.AbstractAnnotationConfigSupport

org.springframework.data.gemfire.config.annotation.ContinuousQueryConfiguration

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, ImportAware, EnvironmentAware

@Configuration
public class ContinuousQueryConfiguration
extends AbstractAnnotationConfigSupport
implements ImportAware

The ContinuousQueryConfiguration class is a Spring @Configuration class enabling Continuous Query (CQ) Pivotal GemFire/Apache Geode capabilities in this cache client application.

Since:

2.0.0

Author:

John Blum

See Also:

• Executor
• GemFireCache
• CqQuery
• QueryService
• BeanPostProcessor
• Bean
• Configuration
• ImportAware
• AnnotationAttributes
• AnnotationMetadata
• AbstractAnnotationConfigSupport
• ContinuousQueryDefinition
• ContinuousQueryListener
• ContinuousQueryListenerContainer
• ContinuousQuery
• ErrorHandler

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.data.gemfire.config.annotation.support.AbstractAnnotationConfigSupport

AbstractAnnotationConfigSupport.TypeResolver<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	ORG_SPRINGFRAMEWORK_DATA_GEMFIRE_PACKAGE_NAME
protected static final String	ORG_SPRINGFRAMEWORK_PACKAGE_NAME

Fields inherited from class org.springframework.data.gemfire.config.annotation.support.AbstractAnnotationConfigSupport

INFRASTRUCTURE_ROLES, ORG_SPRINGFRAMEWORK_DATA_GEMFIRE_PACKAGE, ORG_SPRINGFRAMEWORK_PACKAGE, SPRING_DATA_GEMFIRE_PROPERTY_PREFIX

Constructor Summary

Constructors

Constructor	Description
ContinuousQueryConfiguration()

Method Summary

Modifier and Type	Method	Description
BeanPostProcessor	continuousQueryBeanPostProcessor()
ContinuousQueryListenerContainer	continuousQueryListenerContainer(GemFireCache gemfireCache)
protected Class<? extends Annotation>	getAnnotationType()	Returns the Annotation type that configures and creates Continuous Queries for application ContinuousQuery annotated POJO service methods.
protected String	getErrorHandlerBeanName()
protected int	getPhase()
protected String	getPoolName()
protected String	getQueryServiceBeanName()
protected String	getTaskExecutorBeanName()
protected List<ContinuousQueryListenerContainerConfigurer>	resolveContinuousQueryListenerContainerConfigurers()
protected Optional<ErrorHandler>	resolveErrorHandler()
protected Optional<Integer>	resolvePhase()
protected Optional<String>	resolvePoolName()
protected Optional<QueryService>	resolveQueryService()
protected Optional<Executor>	resolveTaskExecutor()
void	setErrorHandlerBeanName(String errorHandlerBeanName)
void	setImportMetadata(AnnotationMetadata importingClassMetadata)
void	setPhase(int phase)
void	setPoolName(String poolName)
void	setQueryServiceBeanName(String queryServiceBeanName)
void	setTaskExecutorBeanName(String taskExecutorBeanName)

Methods inherited from class org.springframework.data.gemfire.config.annotation.support.AbstractAnnotationConfigSupport

arrayOfPropertyNamesFor, arrayOfPropertyNamesFor, asArrayProperty, cacheClientProperty, cacheCompressionProperty, cacheOffHeapProperty, cachePeerProperty, cacheProperty, cacheServerProperty, clusterProperty, diskStoreProperty, entitiesProperty, gatewayReceiverProperty, gatewaySenderProperty, getAnnotationAttributes, getAnnotationAttributes, getAnnotationAttributes, getAnnotationTypeName, getAnnotationTypeSimpleName, getBeanClassLoader, getBeanFactory, getEnvironment, getEvaluationContext, getLog, hasValue, hasValue, hasValue, httpServiceProperty, isAnnotationPresent, isAnnotationPresent, isNotInfrastructureBean, isNotInfrastructureBean, isNotInfrastructureClass, isNotInfrastructureClass, isNotInfrastructureRole, isUserLevelMethod, locatorProperty, logDebug, logDebug, logError, logError, loggingProperty, logInfo, logInfo, logWarning, logWarning, managementProperty, managerProperty, memcachedServiceProperty, namedCacheServerProperty, namedDiskStoreProperty, namedGatewaySenderProperty, namedPoolProperty, newEvaluationContext, newLog, pdxProperty, poolProperty, propertyName, redisServiceProperty, register, register, requireProperty, resolveAnnotation, resolveBeanClass, resolveBeanClass, resolveBeanClass, resolveBeanClassLoader, resolveBeanClassLoader, resolveBeanClassName, resolveProperty, resolveProperty, resolveProperty, resolveProperty, resolveProperty, resolveProperty, resolveProperty, resolveProperty, safeResolveType, securityProperty, serviceProperty, setBeanClassLoader, setBeanFactory, setEnvironment, sslProperty, statsProperty

Methods inherited from class java.lang.Object

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

Field Details

ORG_SPRINGFRAMEWORK_DATA_GEMFIRE_PACKAGE_NAME

protected static final String ORG_SPRINGFRAMEWORK_DATA_GEMFIRE_PACKAGE_NAME

See Also:

• Constant Field Values

ORG_SPRINGFRAMEWORK_PACKAGE_NAME

protected static final String ORG_SPRINGFRAMEWORK_PACKAGE_NAME

See Also:

• Constant Field Values

Constructor Details

ContinuousQueryConfiguration

public ContinuousQueryConfiguration()

Method Details

getAnnotationType

protected Class<? extends Annotation> getAnnotationType()

Returns the Annotation type that configures and creates Continuous Queries for application ContinuousQuery annotated POJO service methods.

Specified by:

getAnnotationType in class AbstractAnnotationConfigSupport

Returns:

the Annotation type that configures and creates Continuous Queries for application ContinuousQuery annotated POJO service methods.

See Also:

• EnableContinuousQueries
• ContinuousQuery
• Annotation
• Class

setImportMetadata

public void setImportMetadata(AnnotationMetadata importingClassMetadata)

Specified by:

setImportMetadata in interface ImportAware

continuousQueryBeanPostProcessor

@Bean
public BeanPostProcessor continuousQueryBeanPostProcessor()

continuousQueryListenerContainer

@Bean
public ContinuousQueryListenerContainer continuousQueryListenerContainer(GemFireCache gemfireCache)

resolveContinuousQueryListenerContainerConfigurers

protected List<ContinuousQueryListenerContainerConfigurer> resolveContinuousQueryListenerContainerConfigurers()

resolveErrorHandler

protected Optional<ErrorHandler> resolveErrorHandler()

resolvePhase

protected Optional<Integer> resolvePhase()

resolvePoolName

protected Optional<String> resolvePoolName()

resolveQueryService

protected Optional<QueryService> resolveQueryService()

resolveTaskExecutor

protected Optional<Executor> resolveTaskExecutor()

setErrorHandlerBeanName

public void setErrorHandlerBeanName(String errorHandlerBeanName)

getErrorHandlerBeanName

protected String getErrorHandlerBeanName()

setPhase

public void setPhase(int phase)

getPhase

protected int getPhase()

setPoolName

public void setPoolName(String poolName)

getPoolName

protected String getPoolName()

setQueryServiceBeanName

public void setQueryServiceBeanName(String queryServiceBeanName)

getQueryServiceBeanName

protected String getQueryServiceBeanName()

setTaskExecutorBeanName

public void setTaskExecutorBeanName(String taskExecutorBeanName)

getTaskExecutorBeanName

protected String getTaskExecutorBeanName()