Bug 37106624 - Build: Intermittent failure in TopicSubscribeCleanupTe…

…sts.shouldCloseSubscribersOnMemberDeparture - harden test

(merge main -> ce/main 111672)

[git-p4: depot-paths = "//dev/coherence-ce/main/": change = 111673]

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

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2023, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -41,6 +41,8 @@
 import org.junit.Test;
 import org.junit.rules.TestName;
 
+import java.util.concurrent.TimeUnit;
+
 import static com.tangosol.net.topic.Subscriber.Name.inGroup;
 
 import static org.hamcrest.CoreMatchers.is;
@@ -58,7 +60,7 @@
 public class TopicSubscribeCleanupTests
     {
     @BeforeClass
-    public static void setup()
+    public static void setup() throws Exception
         {
         System.setProperty(LocalStorage.PROPERTY, "true");
         System.setProperty(Logging.PROPERTY_LEVEL, "9");
@@ -68,7 +70,7 @@ public static void setup()
         System.setProperty("coherence.cluster", "TopicSubscribeCleanupTests");
 
         s_coherence = Coherence.clusterMember();
-        s_coherence.start().join();
+        s_coherence.start().get(5, TimeUnit.MINUTES);
         s_session = s_coherence.getSession();
         }
 
@@ -126,6 +128,9 @@ public void shouldCloseSubscribersOnMemberDeparture() throws Exception
             int cChannel = topic.getChannelCount();
             try (Subscriber<String> subscriberOne = topic.createSubscriber(inGroup("group-one")))
                 {
+                // call receive so we reconnect if disconnected
+                subscriberOne.receive();
+
                 // there is currently one subscribe that should have all channels
                 Eventually.assertDeferred(() -> subscriberOne.getChannels().length, is(cChannel));
                 Eventually.assertDeferred(() -> caches.Subscribers.size(), is(1));