Add streams to cluster recovery test

Author: acogoluegnes

ci/start-cluster.sh

@@ -1,6 +1,6 @@
 #!/usr/bin/env bash
 
-export RABBITMQ_IMAGE=${RABBITMQ_IMAGE:-pivotalrabbitmq/rabbitmq:v4.0.x}
+export RABBITMQ_IMAGE=${RABBITMQ_IMAGE:-pivotalrabbitmq/rabbitmq:main}
 
 wait_for_message() {
   while ! docker logs "$1" | grep -q "$2";

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

@@ -106,6 +106,7 @@ void clusterRestart() {
     int queueCount = 10;
     List<Management.QueueType> queueTypes =
         List.of(
+            Management.QueueType.STREAM,
             Management.QueueType.QUORUM,
             Management.QueueType.CLASSIC,
             Management.QueueType.CLASSIC);