Skip to content

Commit dbec8b8

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

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

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
@@ -584,7 +584,7 @@ private static void cleanupCompositeExecutor(CompositeExecutor compositeExec) th
584584
TestUtils.getPropertyValue(compositeExec, "secondaryTaskExecutor", DisposableBean.class).destroy();
585585
}
586586

587-
@Test
587+
@RetryingTest(10)
588588
public void testAllMessagesDelivered() throws Exception {
589589
final int numberOfSockets = 10;
590590
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
@@ -53,7 +53,7 @@
5353
@DisabledOnOs(value = OS.MAC, disabledReason = "Multicast tests don't work on MacOS")
5454
public class DatagramPacketMulticastSendingHandlerTests implements TestApplicationContextAware {
5555

56-
@RetryingTest(10)
56+
@RetryingTest(20)
5757
public void verifySendMulticast(MulticastCondition multicastCondition) throws Exception {
5858
MulticastSocket socket;
5959
try {
@@ -122,7 +122,7 @@ public void verifySendMulticast(MulticastCondition multicastCondition) throws Ex
122122
socket.close();
123123
}
124124

125-
@RetryingTest(10)
125+
@RetryingTest(20)
126126
public void verifySendMulticastWithAcks(MulticastCondition multicastCondition) throws Exception {
127127
MulticastSocket socket = new MulticastSocket();
128128
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
@@ -258,7 +258,7 @@ public void testUnicastSender() {
258258
}
259259

260260
@SuppressWarnings("unchecked")
261-
@RetryingTest(10)
261+
@RetryingTest(20)
262262
public void testMulticastReceiver(MulticastCondition multicastCondition) throws Exception {
263263
QueueChannel channel = new QueueChannel(2);
264264
MulticastReceivingChannelAdapter adapter =

0 commit comments

Comments
 (0)