Skip to content

Commit 64c7cdf

Browse files
committed
actually use the secondaryChannel
1 parent 82cd530 commit 64c7cdf

File tree

1 file changed

+3
-3
lines changed
  • test/src/com/rabbitmq/client/test/functional

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -101,11 +101,11 @@ public void testReject()
101101
long tag1 = checkDelivery(channel.basicGet(q, false), m1, false);
102102
long tag2 = checkDelivery(channel.basicGet(q, false), m2, false);
103103
QueueingConsumer c = new QueueingConsumer(secondaryChannel);
104-
String consumerTag = channel.basicConsume(q, false, c);
104+
String consumerTag = secondaryChannel.basicConsume(q, false, c);
105105
channel.basicReject(tag2, true);
106106
long tag3 = checkDelivery(c.nextDelivery(), m2, true);
107-
channel.basicCancel(consumerTag);
108-
channel.basicReject(tag3, false);
107+
secondaryChannel.basicCancel(consumerTag);
108+
secondaryChannel.basicReject(tag3, false);
109109
assertNull(channel.basicGet(q, false));
110110
channel.basicAck(tag1, false);
111111
channel.basicReject(tag3, false);

0 commit comments

Comments
 (0)