Prefer IPv4 for UDP tests

* Enable UDP tests back

**Auto-cherry-pick to `7.0.x` & `6.5.x`**

Author: artembilan

build.gradle

@@ -625,7 +625,8 @@ project('spring-integration-ip') {
 
     tasks.withType(JavaForkOptions) {
         jvmArgs '--add-opens', 'java.base/java.nio.channels.spi=ALL-UNNAMED',
-                '--add-opens', 'java.base/java.util=ALL-UNNAMED'
+                '--add-opens', 'java.base/java.util=ALL-UNNAMED',
+				'-Djava.net.preferIPv4Stack=true'
     }
 }
 

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

@@ -29,8 +29,6 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.condition.DisabledOnOs;
-import org.junit.jupiter.api.condition.OS;
 
 import org.springframework.core.task.SimpleAsyncTaskExecutor;
 import org.springframework.integration.ip.IpHeaders;
@@ -50,7 +48,6 @@
  * @since 2.0
  */
 @Multicast
-@DisabledOnOs(value = OS.MAC, disabledReason = "Multicast tests don't work on MacOS")
 public class DatagramPacketMulticastSendingHandlerTests implements TestApplicationContextAware {
 
 	@Test
@@ -64,7 +61,7 @@ public void verifySendMulticast(MulticastCondition multicastCondition) throws Ex
 		}
 		final int testPort = socket.getLocalPort();
 		final String multicastAddress = multicastCondition.getGroup();
-		final String payload = "foo";
+		final String payload = "test";
 		final CountDownLatch listening = new CountDownLatch(2);
 		final CountDownLatch received = new CountDownLatch(2);
 		Runnable catcher = () -> {
@@ -94,7 +91,7 @@ public void verifySendMulticast(MulticastCondition multicastCondition) throws Ex
 		Executor executor = new SimpleAsyncTaskExecutor("verifySendMulticast-");
 		executor.execute(catcher);
 		executor.execute(catcher);
-		assertThat(listening.await(10000, TimeUnit.MILLISECONDS)).isTrue();
+		assertThat(listening.await(20, TimeUnit.SECONDS)).isTrue();
 		MulticastSendingMessageHandler handler = new MulticastSendingMessageHandler(multicastAddress, testPort);
 		handler.setBeanFactory(TEST_INTEGRATION_CONTEXT);
 		NetworkInterface nic = multicastCondition.getNic();
@@ -117,26 +114,19 @@ public void verifySendMulticast(MulticastCondition multicastCondition) throws Ex
 		}
 		handler.afterPropertiesSet();
 		handler.handleMessage(MessageBuilder.withPayload(payload).build());
-		assertThat(received.await(10000, TimeUnit.MILLISECONDS)).isTrue();
+		assertThat(received.await(20000, TimeUnit.MILLISECONDS)).isTrue();
 		handler.stop();
 		socket.close();
 	}
 
 	@Test
 	public void verifySendMulticastWithAcks(MulticastCondition multicastCondition) throws Exception {
-
-		MulticastSocket socket;
-		try {
-			socket = new MulticastSocket();
-		}
-		catch (Exception e) {
-			return;
-		}
+		MulticastSocket socket = new MulticastSocket();
 		final int testPort = socket.getLocalPort();
 		final AtomicInteger ackPort = new AtomicInteger();
 
 		final String multicastAddress = multicastCondition.getGroup();
-		final String payload = "foobar";
+		final String payload = "test_test";
 		final CountDownLatch listening = new CountDownLatch(2);
 		final CountDownLatch ackListening = new CountDownLatch(1);
 		final CountDownLatch ackSent = new CountDownLatch(2);
@@ -151,14 +141,14 @@ public void verifySendMulticastWithAcks(MulticastCondition multicastCondition) t
 				InetAddress group = InetAddress.getByName(multicastAddress);
 				socket1.joinGroup(new InetSocketAddress(group, 0), null);
 				listening.countDown();
-				assertThat(ackListening.await(10, TimeUnit.SECONDS)).isTrue();
+				assertThat(ackListening.await(20, TimeUnit.SECONDS)).isTrue();
 				socket1.receive(receivedPacket);
 				socket1.close();
 				byte[] src = receivedPacket.getData();
 				int length = receivedPacket.getLength();
 				int offset = receivedPacket.getOffset();
-				byte[] dest = new byte[6];
-				System.arraycopy(src, offset + length - 6, dest, 0, 6);
+				byte[] dest = new byte[9];
+				System.arraycopy(src, offset + length - 9, dest, 0, 9);
 				assertThat(new String(dest)).isEqualTo(payload);
 				DatagramPacketMessageMapper mapper = new DatagramPacketMessageMapper();
 				mapper.setAcknowledge(true);
@@ -196,9 +186,9 @@ public void verifySendMulticastWithAcks(MulticastCondition multicastCondition) t
 		Executor executor = new SimpleAsyncTaskExecutor("verifySendMulticastWithAcks-");
 		executor.execute(catcher);
 		executor.execute(catcher);
-		assertThat(listening.await(10000, TimeUnit.MILLISECONDS)).isTrue();
+		assertThat(listening.await(20000, TimeUnit.MILLISECONDS)).isTrue();
 		MulticastSendingMessageHandler handler =
-				new MulticastSendingMessageHandler(multicastAddress, testPort, true, true, "localhost", 0, 10000);
+				new MulticastSendingMessageHandler(multicastAddress, testPort, true, true, "localhost", 0, 20000);
 
 		if (nic != null) {
 			String hostName = null;
@@ -225,7 +215,7 @@ public void verifySendMulticastWithAcks(MulticastCondition multicastCondition) t
 		ackPort.set(handler.getAckPort());
 		ackListening.countDown();
 		handler.handleMessage(MessageBuilder.withPayload(payload).build());
-		assertThat(ackSent.await(10000, TimeUnit.MILLISECONDS)).isTrue();
+		assertThat(ackSent.await(20000, TimeUnit.MILLISECONDS)).isTrue();
 		handler.stop();
 		socket.close();
 	}

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

@@ -30,10 +30,7 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicReference;
 
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.condition.DisabledOnOs;
-import org.junit.jupiter.api.condition.OS;
 
 import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
@@ -48,7 +45,6 @@
 import org.springframework.integration.ip.udp.outbound.UnicastSendingMessageHandler;
 import org.springframework.integration.ip.util.SocketTestUtils;
 import org.springframework.integration.support.MessageBuilder;
-import org.springframework.integration.test.condition.LogLevels;
 import org.springframework.integration.test.support.TestApplicationContextAware;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.SubscribableChannel;
@@ -66,7 +62,6 @@
  *
  */
 @Multicast
-@LogLevels(categories = "org.springframework.integration.ip.udp", level = "TRACE")
 public class UdpChannelAdapterTests implements TestApplicationContextAware {
 
 	@Test
@@ -260,7 +255,6 @@ public void testUnicastSender() {
 
 	@SuppressWarnings("unchecked")
 	@Test
-	@Disabled("Fails on Java > 17")
 	public void testMulticastReceiver(MulticastCondition multicastCondition) throws Exception {
 		QueueChannel channel = new QueueChannel(2);
 		MulticastReceivingChannelAdapter adapter =
@@ -309,7 +303,6 @@ public void testMulticastReceiver(MulticastCondition multicastCondition) throws
 
 	@SuppressWarnings("unchecked")
 	@Test
-	@DisabledOnOs(value = OS.MAC, disabledReason = "Multicast tests don't work on MacOS")
 	public void testMulticastSender(MulticastCondition multicastCondition) {
 		QueueChannel channel = new QueueChannel(2);
 		UnicastReceivingChannelAdapter adapter =
@@ -378,12 +371,12 @@ public void testSocketExpression() throws Exception {
 		UnicastReceivingChannelAdapter adapter = context.getBean(UnicastReceivingChannelAdapter.class);
 		SocketTestUtils.waitListening(adapter);
 		int receiverServerPort = adapter.getPort();
-		DatagramPacket packet = new DatagramPacket("foo".getBytes(), 3);
+		DatagramPacket packet = new DatagramPacket("test".getBytes(), 4);
 		packet.setSocketAddress(new InetSocketAddress("localhost", receiverServerPort));
 		DatagramSocket socket = new DatagramSocket();
 		socket.send(packet);
 		socket.receive(packet);
-		assertThat(new String(packet.getData())).isEqualTo("FOO");
+		assertThat(new String(packet.getData())).isEqualTo("TEST");
 		assertThat(packet.getPort()).isEqualTo(receiverServerPort);
 		socket.close();
 		context.close();