We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 15158f0 commit 58cb100Copy full SHA for 58cb100
test/src/com/rabbitmq/examples/MulticastMain.java
@@ -105,9 +105,9 @@ public static void main(String[] args) {
105
Channel channel = conn.createChannel();
106
if (consumerTxSize > 0) channel.txSelect();
107
channel.exchangeDeclare(exchangeName, exchangeType);
108
- String queueName = "consumer-" + UUID.randomUUID();
109
- channel.queueDeclare(queueName, flags.contains("persistent"),
110
- true, false, null);
+ String queueName =
+ channel.queueDeclare("", flags.contains("persistent"),
+ true, false, null).getQueue();
111
QueueingConsumer consumer = new QueueingConsumer(channel);
112
if (prefetchCount > 0) channel.basicQos(prefetchCount);
113
channel.basicConsume(queueName, autoAck, consumer);
0 commit comments