Spring/spring-boot-data-geode
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Register a ClientCacheConfigurer to enable subscriptions on the ClientCache instance.

Browse Source 
Fix @ConditionalOnBean to be conditional on a bean of type o.s.d.g.client.ClientCacheFactoryBean.

Remove @AutoConfigureAfter the ClientCacheAutoConfiguration.
This commit is contained in:
John Blum
2018-05-24 12:55:38 -07:00
parent 0b3c81fe0b
commit 93767f5ffb
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
geode-spring-boot-starter/src/main/java/org/springframework/boot/data/geode/autoconfigure/ContinuousQueryAutoConfiguration.java
View File

@@ -17,11 +17,13 @@
package org.springframework.boot.data.geode.autoconfigure;
import org.apache.geode.cache.client.ClientCache;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.gemfire.client.ClientCacheFactoryBean;
import org.springframework.data.gemfire.config.annotation.ClientCacheConfigurer;
import org.springframework.data.gemfire.config.annotation.EnableContinuousQueries;
/**
@@ -29,20 +31,22 @@ import org.springframework.data.gemfire.config.annotation.EnableContinuousQuerie
* functionality in a {@link ClientCache} application.
*
* @author John Blum
* @see org.apache.geode.cache.Cache
* @see org.apache.geode.cache.GemFireCache
* @see org.apache.geode.cache.client.ClientCache
* @see org.springframework.boot.data.geode.autoconfigure.ClientCacheAutoConfiguration
* @see org.springframework.boot.autoconfigure.EnableAutoConfiguration
* @see org.springframework.context.annotation.Configuration
* @see org.springframework.data.gemfire.client.ClientCacheFactoryBean
* @see org.springframework.data.gemfire.config.annotation.EnableContinuousQueries
* @since 1.0.0
*/
@Configuration
@ConditionalOnBean(ClientCache.class)
@ConditionalOnBean(ClientCacheFactoryBean.class)
@ConditionalOnMissingBean(name = "continuousQueryBeanPostProcessor")
@AutoConfigureAfter(ClientCacheAutoConfiguration.class)
@EnableContinuousQueries
@SuppressWarnings("unused")
public class ContinuousQueryAutoConfiguration {
@Bean
public ClientCacheConfigurer enableSubscriptionClientCacheConfigurer() {
return (beanName, clientCacheFactoryBean) -> clientCacheFactoryBean.setSubscriptionEnabled(true);
}
}