Add tests for producer/consumer name strategy

In performance tool.

Author: acogoluegnes

src/test/java/com/rabbitmq/stream/perf/StreamPerfTestTest.java

@@ -187,7 +187,7 @@ void offsetShouldBeStoredWhenOptionIsEnabled() throws Exception {
   void offsetShouldNotBeStoredWhenOptionIsNotEnabled() throws Exception {
     Future<?> run = run(builder());
     waitUntilStreamExists(s);
-    String consumerName = s + "-0"; // convention
+    String consumerName = s + "-0"; // default value when offset tracking is enabled
     assertThat(client.queryOffset(consumerName, s)).isZero();
     waitOneSecond();
     assertThat(client.queryOffset(consumerName, s)).isZero();
@@ -211,7 +211,7 @@ void publishingSequenceShouldBeStoredWhenProducerNamesAreSet() throws Exception
   void publishingSequenceShouldNotBeStoredWhenProducerNamesAreNotSet() throws Exception {
     Future<?> run = run(builder());
     waitUntilStreamExists(s);
-    String producerName = s + "-0"; // convention
+    String producerName = s + "-0"; // shooting in the dark here
     assertThat(client.queryPublisherSequence(producerName, s)).isZero();
     waitOneSecond();
     assertThat(client.queryPublisherSequence(producerName, s)).isZero();

src/test/java/com/rabbitmq/stream/perf/UtilsTest.java

@@ -22,6 +22,7 @@
 import com.rabbitmq.stream.OffsetSpecification;
 import com.rabbitmq.stream.compression.Compression;
 import com.rabbitmq.stream.perf.Utils.CompressionTypeConverter;
+import com.rabbitmq.stream.perf.Utils.NameStrategyConverter;
 import com.rabbitmq.stream.perf.Utils.PatternNameStrategy;
 import com.rabbitmq.stream.perf.Utils.RangeTypeConverter;
 import com.rabbitmq.stream.perf.Utils.SniServerNamesConverter;
@@ -30,6 +31,7 @@
 import java.util.List;
 import java.util.Locale;
 import java.util.Random;
+import java.util.UUID;
 import java.util.function.BiFunction;
 import java.util.stream.IntStream;
 import java.util.stream.LongStream;
@@ -147,6 +149,31 @@ void consumerNameStrategy(String pattern, String expected) {
     assertThat(strategy.apply("s1", 2)).isEqualTo(expected);
   }
 
+  @Test
+  void producerConsumerNameStrategyConverterShouldReturnUuidWhenAskedForUuid() {
+    NameStrategyConverter nameStrategyConverter = new NameStrategyConverter();
+    BiFunction<String, Integer, String> nameStrategy = nameStrategyConverter.convert("uuid");
+    String name = nameStrategy.apply("stream", 1);
+    UUID.fromString(name);
+    assertThat(nameStrategy.apply("stream", 1)).isNotEqualTo(name);
+  }
+
+  @Test
+  void producerConsumerNameStrategyConverterShouldReturnEmptyStringWhenPatternIsEmptyString() {
+    NameStrategyConverter nameStrategyConverter = new NameStrategyConverter();
+    BiFunction<String, Integer, String> nameStrategy = nameStrategyConverter.convert("");
+    assertThat(nameStrategy.apply("stream", 1)).isEmpty();
+    assertThat(nameStrategy.apply("stream", 2)).isEmpty();
+  }
+
+  @Test
+  void producerConsumerNameStrategyConverterShouldReturnPatternStrategyWhenAsked() {
+    NameStrategyConverter nameStrategyConverter = new NameStrategyConverter();
+    BiFunction<String, Integer, String> nameStrategy = nameStrategyConverter.convert("stream-%s-consumer-%d");
+    assertThat(nameStrategy).isInstanceOf(PatternNameStrategy.class);
+    assertThat(nameStrategy.apply("s1", 2)).isEqualTo("stream-s1-consumer-2");
+  }
+
   @Test
   void sniServerNamesConverter() throws Exception {
     SniServerNamesConverter converter = new SniServerNamesConverter();