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:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.annotation.ImportAware, org.springframework.context.EnvironmentAware
@Configuration public class ContinuousQueryConfiguration extends AbstractAnnotationConfigSupport implements org.springframework.context.annotation.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
See Also:

  • Field Details

    • ORG_SPRINGFRAMEWORK_DATA_GEMFIRE_PACKAGE_NAME

      protected static final String ORG_SPRINGFRAMEWORK_DATA_GEMFIRE_PACKAGE_NAME
      See Also:

    • ORG_SPRINGFRAMEWORK_PACKAGE_NAME

      protected static final String ORG_SPRINGFRAMEWORK_PACKAGE_NAME
      See Also:

  • 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:

    • setImportMetadata

      public void setImportMetadata(org.springframework.core.type.AnnotationMetadata importingClassMetadata)
      Specified by:
      setImportMetadata in interface org.springframework.context.annotation.ImportAware

    • continuousQueryBeanPostProcessor

      @Bean public org.springframework.beans.factory.config.BeanPostProcessor continuousQueryBeanPostProcessor()

    • continuousQueryListenerContainer

      @Bean public ContinuousQueryListenerContainer continuousQueryListenerContainer(org.apache.geode.cache.GemFireCache gemfireCache)

    • resolveContinuousQueryListenerContainerConfigurers

      protected List<ContinuousQueryListenerContainerConfigurer> resolveContinuousQueryListenerContainerConfigurers()

    • resolveErrorHandler

      protected Optional<org.springframework.util.ErrorHandler> resolveErrorHandler()

    • resolvePhase

      protected Optional<Integer> resolvePhase()

    • resolvePoolName

      protected Optional<String> resolvePoolName()

    • resolveQueryService

      protected Optional<org.apache.geode.cache.query.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()