Add test to check SAC must have a name

References #46, rabbitmq/rabbitmq-server#3753

Author: acogoluegnes

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

@@ -13,7 +13,9 @@
 // [email protected].
 package com.rabbitmq.stream.impl;
 
+import static com.rabbitmq.stream.impl.TestUtils.ResponseConditions.ko;
 import static com.rabbitmq.stream.impl.TestUtils.ResponseConditions.ok;
+import static com.rabbitmq.stream.impl.TestUtils.ResponseConditions.responseCode;
 import static com.rabbitmq.stream.impl.TestUtils.b;
 import static com.rabbitmq.stream.impl.TestUtils.declareSuperStreamTopology;
 import static com.rabbitmq.stream.impl.TestUtils.deleteSuperStreamTopology;
@@ -574,4 +576,17 @@ void superStreamRebalancingShouldWorkWhilePublishing(TestInfo info) throws Excep
       deleteSuperStreamTopology(c, superStream, 3);
     }
   }
+
+  @Test
+  void singleActiveConsumerMustHaveName() {
+    Client client = cf.get();
+    Response response =
+        client.subscribe(
+            b(0),
+            stream,
+            OffsetSpecification.first(),
+            10,
+            Collections.singletonMap("single-active-consumer", "true"));
+    assertThat(response).is(ko()).has(responseCode(Constants.RESPONSE_CODE_PRECONDITION_FAILED));
+  }
 }

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

@@ -369,11 +369,11 @@ static CountDownLatchAssert latchAssert(AtomicReference<CountDownLatch> latchRef
   static class ResponseConditions {
 
     static Condition<Response> ok() {
-      return new Condition<>(Response::isOk, "Response should be OK");
+      return new Condition<>(Response::isOk, "OK");
     }
 
     static Condition<Response> ko() {
-      return new Condition<>(response -> !response.isOk(), "Response should be OK");
+      return new Condition<>(response -> !response.isOk(), "KO");
     }
 
     static Condition<Response> responseCode(short expectedResponse) {