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

Increase receive timeout in ZeroMqMHTests

Browse Source
This commit is contained in:
Artem Bilan
2021-01-29 12:43:08 -05:00
parent 1c6cf560d7
commit 73d9b8cccd
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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 =