This is an automated email from the ASF dual-hosted git repository. bschuchardt pushed a commit to branch feature/GEODE-7617 in repository https://gitbox.apache.org/repos/asf/geode.git
commit 90e219fa408cb9e119295ee5f277a66827e2cab9 Author: Bruce Schuchardt <[email protected]> AuthorDate: Mon Dec 23 09:27:50 2019 -0800 GEODE-7617: CI failure: GeodeClientClusterManagementSSLTest. getServiceUseClientSSLConfig add an await() so that the cluster configuration service has time to spin up. --- .../internal/rest/GeodeClientClusterManagementSSLTest.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/rest/GeodeClientClusterManagementSSLTest.java b/geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/rest/GeodeClientClusterManagementSSLTest.java index 281289f..6550959 100644 --- a/geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/rest/GeodeClientClusterManagementSSLTest.java +++ b/geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/rest/GeodeClientClusterManagementSSLTest.java @@ -21,6 +21,7 @@ import static org.apache.geode.distributed.ConfigurationProperties.SSL_KEYSTORE_ import static org.apache.geode.distributed.ConfigurationProperties.SSL_TRUSTSTORE; import static org.apache.geode.distributed.ConfigurationProperties.SSL_TRUSTSTORE_PASSWORD; import static org.apache.geode.management.builder.ClusterManagementServiceBuilder.buildWithCache; +import static org.apache.geode.test.awaitility.GeodeAwaitility.await; import static org.assertj.core.api.Assertions.assertThat; import java.io.File; @@ -65,9 +66,11 @@ public class GeodeClientClusterManagementSSLTest { @Test public void getServiceUseClientSSLConfig() throws Exception { client.invoke(() -> { - ClusterManagementService service = buildWithCache() - .setCache(ClusterStartupRule.getClientCache()).build(); - assertThat(service.isConnected()).isTrue(); + await().untilAsserted(() -> { + ClusterManagementService service = buildWithCache() + .setCache(ClusterStartupRule.getClientCache()).build(); + assertThat(service.isConnected()).isTrue(); + }); }); } }
