You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by es...@apache.org on 2021/08/23 22:54:28 UTC
[geode] branch support/1.13 updated: GEODE-9071: Add wait before
check cq listener invocations. (#6785)
This is an automated email from the ASF dual-hosted git repository.
eshu11 pushed a commit to branch support/1.13
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/support/1.13 by this push:
new a1cd4ea GEODE-9071: Add wait before check cq listener invocations. (#6785)
a1cd4ea is described below
commit a1cd4ea85a08138df497045fb31d23510631daae
Author: Eric Shu <es...@pivotal.io>
AuthorDate: Mon Aug 23 10:09:56 2021 -0700
GEODE-9071: Add wait before check cq listener invocations. (#6785)
* Cq events sent to client asynchronously. Need to wait events are
all delivered.
(cherry picked from commit 018fb585b1750a3186ad4693744ed5630d869182)
---
.../cache/query/cq/dunit/PartitionedRegionCqQueryDUnitTest.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/dunit/PartitionedRegionCqQueryDUnitTest.java b/geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/dunit/PartitionedRegionCqQueryDUnitTest.java
index 3905fd2..49784a9 100644
--- a/geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/dunit/PartitionedRegionCqQueryDUnitTest.java
+++ b/geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/dunit/PartitionedRegionCqQueryDUnitTest.java
@@ -16,6 +16,7 @@ package org.apache.geode.cache.query.cq.dunit;
import static org.apache.geode.cache.Region.SEPARATOR;
import static org.apache.geode.distributed.ConfigurationProperties.LOG_LEVEL;
+import static org.apache.geode.test.awaitility.GeodeAwaitility.await;
import static org.apache.geode.test.dunit.Assert.assertEquals;
import static org.apache.geode.test.dunit.Assert.assertFalse;
import static org.apache.geode.test.dunit.Assert.assertNotNull;
@@ -177,7 +178,8 @@ public class PartitionedRegionCqQueryDUnitTest extends JUnit4CacheTestCase {
.isNotNull();
CqQueryTestListener cqListener =
(CqQueryTestListener) cqQuery.getCqAttributes().getCqListener();
- assertThat(cqListener.getTotalEventCount()).isEqualTo(numObjects - 1);
+ await().untilAsserted(
+ () -> assertThat(cqListener.getTotalEventCount()).isEqualTo(numObjects - 1));
});
cqHelper.closeClient(client);
@@ -242,7 +244,8 @@ public class PartitionedRegionCqQueryDUnitTest extends JUnit4CacheTestCase {
.isNotNull();
CqQueryTestListener cqListener =
(CqQueryTestListener) cqQuery.getCqAttributes().getCqListener();
- assertThat(cqListener.getTotalEventCount()).isEqualTo(numObjects - 1);
+ await().untilAsserted(
+ () -> assertThat(cqListener.getTotalEventCount()).isEqualTo(numObjects - 1));
});
cqHelper.closeClient(client);