diff --git a/spring-integration-core/src/test/java/org/springframework/integration/channel/PriorityChannelTests.java b/spring-integration-core/src/test/java/org/springframework/integration/channel/PriorityChannelTests.java index 5467513193..2038959aca 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/channel/PriorityChannelTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/channel/PriorityChannelTests.java @@ -182,6 +182,7 @@ public class PriorityChannelTests { } }); assertFalse(sentSecondMessage.get()); + Thread.sleep(500); Message message1 = channel.receive(); assertNotNull(message1); assertEquals("test-1", message1.getPayload());