Skip to content

Commit 4061704

Browse files
committed
Clarify comment when skipping binding to default exchange
It's not possible to bind to default exchange. References #43 and #44.
1 parent c061038 commit 4061704

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/rabbitmq/perf/MulticastParams.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,8 @@ public List<String> configureQueues(Connection connection, String id) throws IOE
292292
queueArguments).getQueue();
293293
}
294294
generatedQueueNames.add(qName);
295-
// not allowed to bind to the default exchange
295+
// skipping binding to default exchange,
296+
// as it's not possible to explicitly bind to it.
296297
if (!"".equals(exchangeName) && !"amq.default".equals(exchangeName)) {
297298
channel.queueBind(qName, exchangeName, id);
298299
}

0 commit comments

Comments
 (0)