Skip to content

Commit 69226ad

Browse files
committed
Register publish ID before sending message
(cherry picked from commit 34b2f30)
1 parent 3ff01cc commit 69226ad

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/test/java/com/rabbitmq/client/test/server/EffectVisibilityCrossNodeTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,8 +92,8 @@ protected void releaseResources() throws IOException {
9292
confirmLatch.set(new CountDownLatch(1));
9393
for (int j = 0; j < MESSAGES_PER_BATCH; j++) {
9494
long publishId = channel.getNextPublishSeqNo();
95-
channel.basicPublish("amq.fanout", "", null, msg);
9695
publishIds.add(publishId);
96+
channel.basicPublish("amq.fanout", "", null, msg);
9797
}
9898
boolean confirmed = confirmLatch.get().await(10, TimeUnit.SECONDS);
9999
if (!confirmed) {

0 commit comments

Comments
 (0)