feat(queueType): Allow to set queueType from client

Author: juancgalvis

async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/InstanceIdentifier.java

@@ -3,12 +3,20 @@
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
 
+import java.util.UUID;
+
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public class InstanceIdentifier {
+    private static final String INSTANCE_ID = UUID.randomUUID().toString().replace("-", "");
+
     public static String getInstanceId(String kind) {
+        return getInstanceId(kind, INSTANCE_ID);
+    }
+
+    public static String getInstanceId(String kind, String defaultHost) {
         String host = System.getenv("HOSTNAME");
         if (host == null || host.isEmpty()) {
-            return kind;
+            return defaultHost + "-" + kind;
         }
         return host + "-" + kind;
     }

async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/InstanceIdentifierTest.java

@@ -0,0 +1,21 @@
+package org.reactivecommons.async.rabbit;
+
+import org.junit.jupiter.api.Test;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+class InstanceIdentifierTest {
+
+    @Test
+    void shouldGetInstanceIdFromUuid() {
+        String instanceId = InstanceIdentifier.getInstanceId("events");
+        var expectedLength = 39;
+        assertThat(instanceId).endsWith("-events").hasSize(expectedLength);
+    }
+
+    @Test
+    void shouldGetInstanceIdFromEnv() {
+        String instanceId = InstanceIdentifier.getInstanceId("events", "host123");
+        assertThat(instanceId).isEqualTo("host123-events");
+    }
+}

async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/communications/TopologyCreatorTest.java

@@ -0,0 +1,42 @@
+package org.reactivecommons.async.rabbit.communications;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import reactor.rabbitmq.QueueSpecification;
+import reactor.rabbitmq.Sender;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@ExtendWith(MockitoExtension.class)
+class TopologyCreatorTest {
+    @Mock
+    private Sender sender;
+
+    private TopologyCreator creator;
+
+    @BeforeEach
+    void setUp() {
+        creator = new TopologyCreator(sender, "quorum");
+    }
+
+    @Test
+    void shouldInjectQueueType() {
+        QueueSpecification spec = creator.fillQueueType(QueueSpecification.queue("durable"));
+        assertThat(spec.getArguments()).containsEntry("x-queue-type", "quorum");
+    }
+
+    @Test
+    void shouldForceClassicQueueTypeWhenAutodelete() {
+        QueueSpecification spec = creator.fillQueueType(QueueSpecification.queue("autodelete").autoDelete(true));
+        assertThat(spec.getArguments()).containsEntry("x-queue-type", "classic");
+    }
+
+    @Test
+    void shouldForceClassicQueueTypeWhenExclusive() {
+        QueueSpecification spec = creator.fillQueueType(QueueSpecification.queue("exclusive").exclusive(true));
+        assertThat(spec.getArguments()).containsEntry("x-queue-type", "classic");
+    }
+}