2016-11-13 28 views
0

我试图向ClientCache注册cq查询时卡住了。仍然得到此异常:无法在Apache Geode上注册新的CQ查询

CqService is not available. 
java.lang.IllegalStateException: CqService is not available. 
at org.apache.geode.cache.query.internal.cq.MissingCqService.start(MissingCqService.java:171) 
at org.apache.geode.cache.query.internal.DefaultQueryService.getCqService(DefaultQueryService.java:777) 
at org.apache.geode.cache.query.internal.DefaultQueryService.newCq(DefaultQueryService.java:486) 

客户端缓存如下创建:

def client(): ClientCache = new ClientCacheFactory() 
.setPdxPersistent(true) 
.setPdxSerializer(new ReflectionBasedAutoSerializer(false, "org.geode.importer.domain.FooBar")) 
.addPoolLocator(ConfigProvider.locator.host, ConfigProvider.locator.port) 
.setPoolSubscriptionEnabled(true) 
.create() 

,并建议solution没有帮助。实际库版本是:

"org.apache.geode" % "geode-core" % "1.0.0-incubating" 

回答

0

您将不得不将geode-cq作为依赖项。在gradle中

compile 'org.apache.geode:geode-cq:1.0.0-incubating' 
+0

感谢您的支持,似乎是合理的决定放入其他模块。然而,我刚刚切换到事件处理程序,它按预期工作,没有额外的依赖关系。 – dwarszawski