Hi all,
I'm trying to create distributed test in geode-wan module that combines
WAN and CQ functionality. When I execute the test case, I always get the
following error:
java.lang.IllegalStateException: CqService is not available.
at
org.apache.geode.cache.query.internal.cq.MissingCqService.start(MissingCqService.java:158)
at
org.apache.geode.cache.query.internal.DefaultQueryService.getCqService(DefaultQueryService.java:829)
at
org.apache.geode.cache.query.internal.DefaultQueryService.newCq(DefaultQueryService.java:569)
at
org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderOperationClusterConfigDUnitTest.lambda$createDurableCQs$96c20508$1(ParallelGatewaySenderOperationClusterConfigDUnitTest.java:126)
It seems that the CqService is statically initialized using java service
provider interface:
- service provider class:
https://github.com/apache/geode/blob/a5bd36f9fa787d3a71c6e6efafed5a7b0fe52d2b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java
- meta-inf.services file:
https://github.com/apache/geode/blob/a5bd36f9fa787d3a71c6e6efafed5a7b0fe52d2b/geode-cq/src/main/resources/META-INF/services/org.apache.geode.cache.query.internal.cq.spi.CqServiceFactory
So if I understood above exception correctly, the CqService cannot be
used in distributed test in geode-wan module, because it won't be
statically initialized in that case. Is this correct?
Do you maybe know how to overcome this issue?
Please feel free to ask any additional information or correct me if I
misunderstood this exception completely.
BRs/Jakov
