Fix RabbitMQ queue declare

saicone · Jan 7, 2024 · bd6e92f · bd6e92f
1 parent 83238f2
commit bd6e92f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/delivery4j-rabbitmq/src/main/java/com/saicone/delivery4j/client/RabbitMQDelivery.java b/delivery4j-rabbitmq/src/main/java/com/saicone/delivery4j/client/RabbitMQDelivery.java
@@ -68,7 +68,7 @@ public void onStart() {
 
             // Second!
             // Create auto-delete queue
-            this.queue = cChannel.queueDeclare(queue, false, true, true, null).getQueue();
+            this.queue = cChannel.queueDeclare("", false, true, true, null).getQueue();
             // With auto-delete pre-channel (exchange in RabbitMQ)
             cChannel.exchangeDeclare(exchange, BuiltinExchangeType.TOPIC, false, true, null);
             // And subscribed channels (routing keys in RabbitMQ)