Skip to content

Commit 7072cf1

Browse files
committed
Increase timeout in ZeroMqMessageHandlerTests
1 parent cd7465a commit 7072cf1

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

spring-integration-zeromq/src/test/java/org/springframework/integration/zeromq/outbound/ZeroMqMessageHandlerTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,8 @@ void testMessageHandlerForPubSub() {
102102

103103
Message<?> testMessage = MessageBuilder.withPayload("test").setHeader("topic", "testTopic").build();
104104

105-
await().untilAsserted(() -> {
105+
await().atMost(Duration.ofSeconds(20)).pollDelay(Duration.ofMillis(100))
106+
.untilAsserted(() -> {
106107
messageHandler.handleMessage(testMessage).subscribe();
107108
ZMsg msg = ZMsg.recvMsg(subSocket);
108109
assertThat(msg).isNotNull();

0 commit comments

Comments
 (0)