Skip to content

Commit f853b00

Browse files
artembilanspring-builds
authored andcommitted
More RetryingTest for UDP and NIO tests
(cherry picked from commit 210eb46)
1 parent 08ff688 commit f853b00

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/TcpNioConnectionTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -595,7 +595,7 @@ private void cleanupCompositeExecutor(CompositeExecutor compositeExec) throws Ex
595595
TestUtils.getPropertyValue(compositeExec, "secondaryTaskExecutor", DisposableBean.class).destroy();
596596
}
597597

598-
@Test
598+
@RetryingTest(10)
599599
public void testAllMessagesDelivered() throws Exception {
600600
final int numberOfSockets = 10;
601601
TcpNioServerConnectionFactory factory = new TcpNioServerConnectionFactory(0);

spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/DatagramPacketMulticastSendingHandlerTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@
5252
@DisabledOnOs(value = OS.MAC, disabledReason = "Multicast tests don't work on MacOS")
5353
public class DatagramPacketMulticastSendingHandlerTests {
5454

55-
@RetryingTest(10)
55+
@RetryingTest(20)
5656
public void verifySendMulticast(MulticastCondition multicastCondition) throws Exception {
5757
MulticastSocket socket;
5858
try {
@@ -121,7 +121,7 @@ public void verifySendMulticast(MulticastCondition multicastCondition) throws Ex
121121
socket.close();
122122
}
123123

124-
@RetryingTest(10)
124+
@RetryingTest(20)
125125
public void verifySendMulticastWithAcks(MulticastCondition multicastCondition) throws Exception {
126126
MulticastSocket socket = new MulticastSocket();
127127
final int testPort = socket.getLocalPort();

spring-integration-ip/src/test/java/org/springframework/integration/ip/udp/UdpChannelAdapterTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -246,7 +246,7 @@ public void testUnicastSender() {
246246
}
247247

248248
@SuppressWarnings("unchecked")
249-
@RetryingTest(10)
249+
@RetryingTest(20)
250250
public void testMulticastReceiver(MulticastCondition multicastCondition) throws Exception {
251251
QueueChannel channel = new QueueChannel(2);
252252
MulticastReceivingChannelAdapter adapter =

0 commit comments

Comments
 (0)