You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2019/04/17 01:04:42 UTC
[geode] branch feature/GEODE-6640 updated: wait for aeq to flush
This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a commit to branch feature/GEODE-6640
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-6640 by this push:
new 0065fc3 wait for aeq to flush
0065fc3 is described below
commit 0065fc3e70b0823ed3d5b8ab3e1d9f334b05fe58
Author: zhouxh <gz...@pivotal.io>
AuthorDate: Tue Apr 16 18:04:11 2019 -0700
wait for aeq to flush
---
.../org/apache/geode/connectors/jdbc/JdbcDistributedTest.java | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
index bc70f8b..b3ee843 100644
--- a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
+++ b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
@@ -352,6 +352,17 @@ public abstract class JdbcDistributedTest implements Serializable {
assertThat(employee2.getName()).isEqualTo("name1");
});
}
+
+ for (MemberVM server : Arrays.asList(server1, server2)) {
+ server.invoke(() -> {
+ String queueName = MappingCommandUtils.createAsyncEventQueueName(REGION_NAME);
+ AsyncEventQueue queue = ClusterStartupRule.getCache().getAsyncEventQueue(queueName);
+ assertThat(queue).isNotNull();
+ await().untilAsserted(() -> {
+ assertThat(queue.size()).isEqualTo(0);
+ });
+ });
+ }
}
@Test