Skip to content

Commit 20bc3a5

Browse files
committed
Make testInt2993IdCacheConcurrency() as @RetryingTest(10)
1 parent d0d9098 commit 20bc3a5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/store/channel/AbstractTxTimeoutMessageStoreTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
import org.apache.commons.logging.Log;
3333
import org.apache.commons.logging.LogFactory;
3434
import org.junit.jupiter.api.Test;
35+
import org.junitpioneer.jupiter.RetryingTest;
3536

3637
import org.springframework.beans.factory.annotation.Autowired;
3738
import org.springframework.beans.factory.annotation.Qualifier;
@@ -130,7 +131,7 @@ public void test() throws InterruptedException {
130131
assertThat(Integer.valueOf(testService.getDuplicateMessagesCount())).isEqualTo(Integer.valueOf(0));
131132
}
132133

133-
@Test
134+
@RetryingTest(10)
134135
public void testInt2993IdCacheConcurrency() throws InterruptedException, ExecutionException {
135136
final String groupId = "testInt2993Group";
136137
for (int i = 0; i < 100; i++) {

0 commit comments

Comments
 (0)