GH-1055: Fix new test race conditions

spring-projects · Jul 30, 2019 · 569024e · 569024e
1 parent bf979dd
commit 569024e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...rg/springframework/amqp/rabbit/core/RabbitTemplatePublisherCallbacksIntegrationTests.java b/...rg/springframework/amqp/rabbit/core/RabbitTemplatePublisherCallbacksIntegrationTests.java
@@ -538,7 +538,7 @@ public void testPublisherConfirmMultipleWithTwoListeners() throws Exception {
 		});
 		final RabbitTemplate template2 = new RabbitTemplate(ccf);
 
-		final CountDownLatch latch2 = new CountDownLatch(1);
+		final CountDownLatch latch2 = new CountDownLatch(2);
 		template2.setConfirmCallback((correlationData, ack, cause) -> {
 			if (ack) {
 				confirms.add(correlationData.getId() + "2");
@@ -601,8 +601,8 @@ public void testConcurrentConfirms() throws Exception {
 				delayAckProcessingLatch.await(2, TimeUnit.SECONDS);
 				// only delay first time through
 				delayAckProcessingLatch.countDown();
-				waitForAll3AcksLatch.countDown();
 				acks.incrementAndGet();
+				waitForAll3AcksLatch.countDown();
 			}
 			catch (InterruptedException e) {
 				e.printStackTrace();