Skip to content

Commit 210eb46

Browse files
committed
More RetryingTest for UDP and NIO tests
**Auto-cherry-pick to `7.0.x` & `6.5.x`**
1 parent bcaaf73 commit 210eb46

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

589-
@Test
589+
@RetryingTest(10)
590590
public void testAllMessagesDelivered() throws Exception {
591591
final int numberOfSockets = 10;
592592
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)