From 73d9b8cccd5a57888ee7d08cda96dc47e1c2cf05 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Fri, 29 Jan 2021 12:43:08 -0500 Subject: [PATCH] Increase receive timeout in ZeroMqMHTests --- .../zeromq/outbound/ZeroMqMessageHandlerTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 8af81d024d..a77a98d509 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 @@ -1,5 +1,5 @@ /* - * Copyright 2020 the original author or authors. + * Copyright 2020-2021 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -77,7 +77,7 @@ public class ZeroMqMessageHandlerTests { @Test void testMessageHandlerForPubSub() throws InterruptedException { ZMQ.Socket subSocket = CONTEXT.createSocket(SocketType.SUB); - subSocket.setReceiveTimeOut(10_000); + subSocket.setReceiveTimeOut(20_000); int port = subSocket.bindToRandomPort("tcp://*"); subSocket.subscribe("test"); @@ -116,7 +116,7 @@ public class ZeroMqMessageHandlerTests { await().until(() -> proxy.getBackendPort() > 0); ZMQ.Socket pullSocket = CONTEXT.createSocket(SocketType.PULL); - pullSocket.setReceiveTimeOut(10_000); + pullSocket.setReceiveTimeOut(20_000); pullSocket.connect("tcp://localhost:" + proxy.getBackendPort()); ZeroMqMessageHandler messageHandler =