0
Apache Geodeで連続問合せを作成しようとしています。しかし、私は私がQueryServiceを作成し、それは素晴らしいだろうCQgeodeで連続問合せを作成できません
ため@Bean
QueryService getQueryService() throws CqException, QueryInvalidException, CqExistsException, CqClosedException, RegionNotFoundException{
ClientCache cache =appContext.getBean(ClientCache.class);
QueryService qservice= cache.getQueryService();
CqAttributesFactory cqf = new CqAttributesFactory();
cqf.addCqListener(new CqListener() {
@Override
public void close() {
// TODO Auto-generated method stub
}
@Override
public void onEvent(CqEvent aCqEvent) {
// TODO Auto-generated method stub
System.out.println("Event Recieved !");
}
@Override
public void onError(CqEvent aCqEvent) {
// TODO Auto-generated method stub
}
});
CqQuery studentTracker=qservice.newCq("StudentQuery","SELECT name from /Student where rollNo==0",cqf.create());
// qservice.executeCqs("/Student");
studentTracker.execute();
// System.out.println(qservice.getCqStatistics().numCqsActive()+" *****************");
studentTracker.close();
return qservice;
}
を登録するための使用していたコードの下に見つけてください
create region --name=Student --type=REPLICATE --enable-statistic=true --enable-subscription-conflation=true
を使用して、私の地域を作成してい
Caused by: java.lang.IllegalStateException: CqService is not available.
at com.gemstone.gemfire.cache.query.internal.cq.MissingCqService.start(MissingCqService.java:171) ~[gemfire-core-1.0.0-incubating.M1.jar:na]
at com.gemstone.gemfire.cache.query.internal.DefaultQueryService.getCqService(DefaultQueryService.java:810) ~[gemfire-core-1.0.0-incubating.M1.jar:na]
at com.gemstone.gemfire.cache.query.internal.DefaultQueryService.newCq(DefaultQueryService.java:595) ~[gemfire-core-1.0.0-incubating.M1.jar:na]
at com.gemfirepo.GedoeConfiguration.getQueryService(GedoeConfiguration.java:79) ~[classes/:na]
at com.gemfirepo.GedoeConfiguration$$EnhancerBySpringCGLIB$$9bd68b16.CGLIB$getQueryService$1(<generated>) ~[classes/:na]
at com.gemfirepo.GedoeConfiguration$$EnhancerBySpringCGLIB$$9bd68b16$$FastClassBySpringCGLIB$$5b2bc172.invoke(<generated>) ~[classes/:na]
at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228) ~[spring-core-4.2.7.RELEASE.jar:4.2.7.RELEASE]
at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:356) ~[spring-context-4.2.7.RELEASE.jar:4.2.7.RELEASE]
at com.gemfirepo.GedoeConfiguration$$EnhancerBySpringCGLIB$$9bd68b16.getQueryService(<generated>) ~[classes/:na]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_45]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_45]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_45]
at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_45]
例外の下の取得誰かがGemfire連続クエリの作業例を共有できる場合に助けてください
あなたの質問も尋ねられました(http://markmail.org/search/?q=list%3Aorg.apache.geode.user+ %3前向きな#クエリ:リスト%3Aorg.apache.geode.user%20order%3前向き+ページ:1 +中:34bjwd4k3uoiy43z +状態:結果)と回答しました(http://markmail.org/search/? q = list%3Aorg.apache.geode.user + order%3Adate-backward#query:リストの%3Aorg.apache.geode.user%20order%3Addate-backward + page:1 + mid:f5xebg7jpuuhxo4e + state:results)のジオードユーザーのメーリングリスト。 –