From 7072cf1ab003d8e595bb72526981cc173bd8c76b Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@vmware.com>
Date: Tue, 22 Jun 2021 12:05:04 -0400
Subject: [PATCH] Increase timeout in ZeroMqMessageHandlerTests

---
 .../integration/zeromq/outbound/ZeroMqMessageHandlerTests.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/spring-integration-zeromq/src/test/java/org/springframework/integration/zeromq/outbound/ZeroMqMessageHandlerTests.java b/spring-integration-zeromq/src/test/java/org/springframework/integration/zeromq/outbound/ZeroMqMessageHandlerTests.java
index ceaba6bec5..edfc63034d 100644
--- a/spring-integration-zeromq/src/test/java/org/springframework/integration/zeromq/outbound/ZeroMqMessageHandlerTests.java
+++ b/spring-integration-zeromq/src/test/java/org/springframework/integration/zeromq/outbound/ZeroMqMessageHandlerTests.java
@@ -102,7 +102,8 @@ public class ZeroMqMessageHandlerTests {
 
 		Message<?> testMessage = MessageBuilder.withPayload("test").setHeader("topic", "testTopic").build();
 
-		await().untilAsserted(() -> {
+		await().atMost(Duration.ofSeconds(20)).pollDelay(Duration.ofMillis(100))
+				.untilAsserted(() -> {
 			messageHandler.handleMessage(testMessage).subscribe();
 			ZMsg msg = ZMsg.recvMsg(subSocket);
 			assertThat(msg).isNotNull();