Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increase poll timeout in MessageGroupQueueTests

Browse Source 
`100` milliseconds is not enough for all the environments
to achieve a proper async barrier
This commit is contained in:
abilan
2023-03-22 16:58:50 -04:00
parent 79870dc78c
commit 047c8f3d9d
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-integration-core/src/test/java/org/springframework/integration/store/MessageGroupQueueTests.java
View File

@@ -28,7 +28,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.Test;
import org.junit.jupiter.api.Test;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.GenericMessage;
@@ -40,6 +40,8 @@ import static org.mockito.Mockito.spy;
/**
* @author Dave Syer
* @author Gary Russell
* @author Artem Bilan
*
* @since 2.0
*/
public class MessageGroupQueueTests {
@@ -74,7 +76,7 @@ public class MessageGroupQueueTests {
CountDownLatch latch2 = new CountDownLatch(1);
exec.execute(() -> {
try {
Message<?> result = queue.poll(100, TimeUnit.MILLISECONDS);
Message<?> result = queue.poll(10, TimeUnit.SECONDS);
if (result != null) {
latch2.countDown();
}
@@ -92,7 +94,7 @@ public class MessageGroupQueueTests {
@Test
public void testSize() throws Exception {
MessageGroupQueue queue = new MessageGroupQueue(new SimpleMessageStore(), "FOO");
queue.put(new GenericMessage<String>("foo"));
queue.put(new GenericMessage<>("foo"));
assertThat(queue.size()).isEqualTo(1);
queue.poll(100, TimeUnit.MILLISECONDS);
assertThat(queue.size()).isEqualTo(0);