Enh 37387063 - [37381796->22.06.12] Topics: general refactoring and h…

…ardening

(merge 14.1.1.2206 -> ce/22.06 113667)

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v22.06/": change = 113668]

prj/test/functional/topics/src/main/java/topics/TopicsRecoveryTests.java

@@ -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 -------------------------------------------