From 87757e16b12c69322daab6db9c5cd42790f7e46e Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Fri, 4 May 2018 13:06:09 -0400 Subject: [PATCH] Add small sleep between adding message to group https://build.spring.io/browse/INT-FATS5IC-497 Fixes `JdbcMessageStoreTests` sporadic failure where there is no guarantee that message are going to be polled from the group the same order they've been inserted Cherry-pick to `5.0.x` (cherry picked from commit 664d67f) --- .../integration/jdbc/store/JdbcMessageStoreTests.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/store/JdbcMessageStoreTests.java b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/store/JdbcMessageStoreTests.java index 68ebee496d..4bbfa4d809 100644 --- a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/store/JdbcMessageStoreTests.java +++ b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/store/JdbcMessageStoreTests.java @@ -386,7 +386,9 @@ public class JdbcMessageStoreTests { String groupId = "X"; messageStore.addMessagesToGroup(groupId, MessageBuilder.withPayload("foo").setCorrelationId(groupId).build()); + Thread.sleep(10); messageStore.addMessagesToGroup(groupId, MessageBuilder.withPayload("bar").setCorrelationId(groupId).build()); + Thread.sleep(10); messageStore.addMessagesToGroup(groupId, MessageBuilder.withPayload("baz").setCorrelationId(groupId).build()); messageStore.addMessagesToGroup("Y", MessageBuilder.withPayload("barA").setCorrelationId(groupId).build(),