diff --git a/build.gradle b/build.gradle index d53b48085e..0333a63068 100644 --- a/build.gradle +++ b/build.gradle @@ -401,10 +401,6 @@ project('spring-integration-ip') { compile project(":spring-integration-core") testCompile project(":spring-integration-stream") } - - test { - jvmArgs '-Djava.net.preferIPv4Stack=true' // Multicast on OS X - } } project('spring-integration-jdbc') { diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastSendingMessageHandler.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastSendingMessageHandler.java index 10aba4a1b7..e2fad624a9 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastSendingMessageHandler.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastSendingMessageHandler.java @@ -256,6 +256,12 @@ public class UnicastSendingMessageHandler extends if (!this.ackThreadRunning) { synchronized(this) { if (!this.ackThreadRunning) { + try { + getSocket(); + } + catch (IOException e) { + logger.error("Error creating socket", e); + } ackLatch = new CountDownLatch(1); this.taskExecutor.execute(this); try {