Adapt test assertions for CI

Make them less multi-threaded, CI workers may not have much parallelism.

Author: acogoluegnes

src/test/java/com/rabbitmq/client/amqp/impl/RecoveryClusterTest.java

@@ -105,37 +105,28 @@ void clusterRestart() {
 
       publisherStates.forEach(PublisherState::start);
 
-      consumerStates.stream()
-          .map(s -> s.waitForNewMessages(10))
-          .parallel()
-          .forEach(s -> assertThat(s).completes());
+      List<Sync> syncs =
+          consumerStates.stream().map(s -> s.waitForNewMessages(10)).collect(toList());
+      syncs.forEach(s -> assertThat(s).completes());
 
       nodes.forEach(Cli::restartNode);
       Cli.rebalance();
 
       waitAtMost(() -> connection.state() == Resource.State.OPEN);
 
-      qqNames.stream()
-          .parallel()
-          .forEach(
-              n -> waitAtMostNoException(TIMEOUT.multipliedBy(2), () -> management.queueInfo(n)));
-      qqNames.stream()
-          .parallel()
-          .forEach(
-              n ->
-                  assertThat(management.queueInfo(n).replicas())
-                      .hasSameSizeAs(nodes)
-                      .containsExactlyInAnyOrderElementsOf(nodes));
-
-      publisherStates.stream()
-          .map(s -> s.waitForNewMessages(10))
-          .parallel()
-          .forEach(s -> assertThat(s).completes());
-
-      consumerStates.stream()
-          .map(s -> s.waitForNewMessages(10))
-          .parallel()
-          .forEach(s -> assertThat(s).completes());
+      qqNames.forEach(
+          n -> waitAtMostNoException(TIMEOUT.multipliedBy(2), () -> management.queueInfo(n)));
+      qqNames.forEach(
+          n ->
+              assertThat(management.queueInfo(n).replicas())
+                  .hasSameSizeAs(nodes)
+                  .containsExactlyInAnyOrderElementsOf(nodes));
+
+      syncs = publisherStates.stream().map(s -> s.waitForNewMessages(10)).collect(toList());
+      syncs.forEach(s -> assertThat(s).completes());
+
+      syncs = consumerStates.stream().map(s -> s.waitForNewMessages(10)).collect(toList());
+      syncs.forEach(s -> assertThat(s).completes());
 
       assertThat(publisherStates).allMatch(s -> s.state() == Resource.State.OPEN);
       assertThat(consumerStates).allMatch(s -> s.state() == Resource.State.OPEN);