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 23:07:50 UTC
[geode] branch support/1.12 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.12
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/support/1.12 by this push:
new f938c4a GEODE-9071: Add wait before check cq listener invocations. (#6785)
f938c4a is described below
commit f938c4a0dd136d9c923b182b9f853f8153e024c0
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 dbb89e9..25d93d6 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
@@ -15,6 +15,7 @@
package org.apache.geode.cache.query.cq.dunit;
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;
@@ -176,7 +177,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);
@@ -241,7 +243,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);