Bug 36964197 - Build: Intermittent failure in TopicChannelCountRecove…

…ryTests.shouldRecoverCorrectChannelCount

(merge main -> ce/main 110686)

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

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

@@ -103,12 +103,25 @@ public void shouldRecoverCorrectChannelCount() throws Exception
         SubscriberId subscriberId = future.get(5, TimeUnit.MINUTES);
         assertThat(subscriberId, is(notNullValue()));
 
+        // the topic in the subscriber JVM should eventually have the correct channel count
+        Eventually.assertDeferred(() -> CreateSubscriber.apply(memberSub, subscriberId, Subscriber::getChannelCount),
+                is(cChannelIncreased));
+
+        // call receive on the subscriber so that we ensure it is connected and should be allocated all channels
+        CreateSubscriber.apply(memberSub, subscriberId, sub ->
+            {
+            sub.receive();
+            return null;
+            });
+
+        // The subscriber should be allocated the correct count of channels
         Eventually.assertDeferred(() -> CreateSubscriber.apply(memberSub, subscriberId, sub ->
                     {
                     int[] anChannel = sub.getChannels();
                     return anChannel == null ? 0 : anChannel.length;
                     }),
                 is(cChannelIncreased));
+
         }