Run only recovery tests

Author: acogoluegnes

.github/workflows/test-pr.yml

@@ -11,38 +11,38 @@ jobs:
 
     steps:
       - uses: actions/checkout@v4
-      - name: Checkout tls-gen
-        uses: actions/checkout@v4
-        with:
-          repository: rabbitmq/tls-gen
-          path: './tls-gen'
+#      - name: Checkout tls-gen
+#        uses: actions/checkout@v4
+#        with:
+#          repository: rabbitmq/tls-gen
+#          path: './tls-gen'
       - name: Set up JDK
         uses: actions/setup-java@v4
         with:
           distribution: 'temurin'
           java-version: '21'
           cache: 'maven'
-      - name: Start broker
-        run: ci/start-broker.sh
-      - name: Test (no dynamic-batch publishing)
-        run: |
-          ./mvnw verify -Drabbitmqctl.bin=DOCKER:rabbitmq \
-            -Drabbitmq.stream.producer.dynamic.batch=false \
-            -Dca.certificate=./tls-gen/basic/result/ca_certificate.pem \
-            -Dclient.certificate=./tls-gen/basic/result/client_$(hostname)_certificate.pem \
-            -Dclient.key=./tls-gen/basic/result/client_$(hostname)_key.pem
-      - name: Test (dynamic-batch publishing)
-        run: |
-          ./mvnw test -Drabbitmqctl.bin=DOCKER:rabbitmq \
-            -Drabbitmq.stream.producer.dynamic.batch=true \
-            -Dca.certificate=./tls-gen/basic/result/ca_certificate.pem \
-            -Dclient.certificate=./tls-gen/basic/result/client_$(hostname)_certificate.pem \
-            -Dclient.key=./tls-gen/basic/result/client_$(hostname)_key.pem
-      - name: Stop broker
-        run: docker stop rabbitmq && docker rm rabbitmq
+#      - name: Start broker
+#        run: ci/start-broker.sh
+#      - name: Test (no dynamic-batch publishing)
+#        run: |
+#          ./mvnw verify -Drabbitmqctl.bin=DOCKER:rabbitmq \
+#            -Drabbitmq.stream.producer.dynamic.batch=false \
+#            -Dca.certificate=./tls-gen/basic/result/ca_certificate.pem \
+#            -Dclient.certificate=./tls-gen/basic/result/client_$(hostname)_certificate.pem \
+#            -Dclient.key=./tls-gen/basic/result/client_$(hostname)_key.pem
+#      - name: Test (dynamic-batch publishing)
+#        run: |
+#          ./mvnw test -Drabbitmqctl.bin=DOCKER:rabbitmq \
+#            -Drabbitmq.stream.producer.dynamic.batch=true \
+#            -Dca.certificate=./tls-gen/basic/result/ca_certificate.pem \
+#            -Dclient.certificate=./tls-gen/basic/result/client_$(hostname)_certificate.pem \
+#            -Dclient.key=./tls-gen/basic/result/client_$(hostname)_key.pem
+#      - name: Stop broker
+#        run: docker stop rabbitmq && docker rm rabbitmq
       - name: Start cluster
         run: ci/start-cluster.sh
       - name: Test against cluster
-        run: ./mvnw test -Dtest="*ClusterTest" -Drabbitmqctl.bin=DOCKER:rabbitmq0
+        run: ./mvnw test -Dtest="RecoveryClusterTest" -Drabbitmqctl.bin=DOCKER:rabbitmq0
       - name: Stop cluster
         run: docker compose --file ci/cluster/docker-compose.yml down

src/main/java/com/rabbitmq/stream/impl/StreamEnvironment.java

@@ -905,11 +905,7 @@ TrackingConsumerRegistration registerTrackingConsumer(
   public String toString() {
     return "{ \"locators\" : ["
         + this.locators.stream()
-            .map(
-                l -> {
-                  Client c = l.nullableClient();
-                  return c == null ? "null" : ("\"" + l.label() + "\"");
-                })
+            .map(l -> quote(l.label()))
             .collect(Collectors.joining(","))
         + "], "
         + Utils.jsonField("producer_client_count", this.producersCoordinator.clientCount())

src/test/java/com/rabbitmq/stream/impl/RecoveryClusterTest.java

@@ -72,9 +72,8 @@ public class RecoveryClusterTest {
   static List<Level> logLevels;
   static List<Class<?>> logClasses =
       List.of(
-          ProducersCoordinator.class,
-          ConsumersCoordinator.class,
-          StreamEnvironment.class,
+//          ProducersCoordinator.class,
+//          ConsumersCoordinator.class,
           AsyncRetry.class,
           StreamEnvironment.class,
           ScheduledExecutorServiceWrapper.class);
@@ -126,9 +125,9 @@ static void tearDownAll() {
 
   @ParameterizedTest
   @CsvSource({
-    "false,false",
+//    "false,false",
     "true,true",
-    "true,false",
+//    "true,false",
   })
   void clusterRestart(boolean useLoadBalancer, boolean forceLeader) throws InterruptedException {
     LOGGER.info(