Skip to content

Commit 6c1b625

Browse files
committed
one ordinary publish is enough
1 parent 261710e commit 6c1b625

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -141,9 +141,7 @@ public void handleNack(long deliveryTag, boolean multiple) throws IOException {
141141
closeAndWaitForRecovery();
142142
expectChannelRecovery(channel);
143143
channel.confirmSelect();
144-
for (int i = 0; i < 1000; i++) {
145-
channel.basicPublish("", q, true, false, null, "mandatory1".getBytes());
146-
}
144+
basicPublishVolatile(q);
147145
waitForConfirms(channel);
148146
wait(latch);
149147
}

0 commit comments

Comments
 (0)