Skip to content

Commit ee3bc75

Browse files
author
Simon MacMullen
committed
Fix stupidity
1 parent f8beb69 commit ee3bc75

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

test/src/com/rabbitmq/examples/perf/Consumer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public void run() {
6666

6767
try {
6868
q = new QueueingConsumer(channel);
69-
channel.basicConsume(queueName, autoAck, q);
69+
channel.basicConsume(queueName, autoAck, "", false, false, args(prefetch), q);
7070

7171
while ((timeLimit == 0 || now < startTime + timeLimit) &&
7272
(msgLimit == 0 || totalMsgCount < msgLimit)) {
@@ -81,7 +81,7 @@ public void run() {
8181
} catch (ConsumerCancelledException e) {
8282
System.out.println("Consumer cancelled by broker. Re-consuming.");
8383
q = new QueueingConsumer(channel);
84-
channel.basicConsume(queueName, autoAck, "consumer-tag", false, false, args(prefetch), q);
84+
channel.basicConsume(queueName, autoAck, "", false, false, args(prefetch), q);
8585
continue;
8686
}
8787
totalMsgCount++;

0 commit comments

Comments
 (0)