Skip to content

Commit 7d95683

Browse files
author
Alexandru Scvortov
committed
workaround for bug 24408
1 parent 01315ed commit 7d95683

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

test/src/com/rabbitmq/client/test/functional/Confirm.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,9 @@ private void declareQueue(String queueName, boolean durable,
6565
private void declareConsumeQueue(String queueName, boolean durable)
6666
throws IOException {
6767
declareQueue(queueName, durable);
68-
channel.basicConsume(queueName, true, defaultConsumer);
68+
// we consume on a different channel to work around bug 24408
69+
// (channels should permit pipelining of mandatory publishes)
70+
connection.createChannel().basicConsume(queueName, true, defaultConsumer);
6971
}
7072

7173
private void declareBindQueue(String queueName, boolean durable)

0 commit comments

Comments
 (0)