diff --git a/prj/test/functional/topics/src/main/java/topics/TopicsRecoveryTests.java b/prj/test/functional/topics/src/main/java/topics/TopicsRecoveryTests.java index 5460398c6158..a7d47fbe1426 100644 --- a/prj/test/functional/topics/src/main/java/topics/TopicsRecoveryTests.java +++ b/prj/test/functional/topics/src/main/java/topics/TopicsRecoveryTests.java @@ -1,5 +1,5 @@ /* - * Copyright (c) 2000, 2024, Oracle and/or its affiliates. + * Copyright (c) 2000, 2025, Oracle and/or its affiliates. * * Licensed under the Universal Permissive License v 1.0 as shown at * https://oss.oracle.com/licenses/upl. @@ -655,10 +655,12 @@ private String getCacheName(String sPrefix) private void restartService(NamedTopic topic) { - Service service = topic.getService(); - String serviceName = service.getInfo().getServiceName(); + PagedTopicService service = (PagedTopicService) topic.getService(); + int cMember = service.getInfo().getServiceMembers().size(); + String serviceName = service.getInfo().getServiceName(); - System.err.println("Stopping topics cache service " + serviceName); + + System.err.println("Stopping topics service " + serviceName); Service serviceFinal = service instanceof SafeCacheService ? ((SafeCacheService) service).getRunningCacheService() @@ -667,8 +669,10 @@ private void restartService(NamedTopic topic) serviceFinal.stop(); // wait for DCS to restart the service Eventually.assertDeferred("Failed to restart service " + service, service::isRunning, is(true)); + Eventually.assertDeferred("Failed to restart service waiting for membership count" + service, + () -> service.getInfo().getServiceMembers().size(), is(cMember)); - System.err.println("Restarted topics cache service " + serviceName); + System.err.println("Restarted topics service " + serviceName); } // ----- inner class: Message -------------------------------------------