From c0ca5a9b895c90ee1b75c30a6420fccb7f0b6bea Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@pivotal.io>
Date: Tue, 24 Nov 2015 11:35:43 -0500
Subject: [PATCH] INT-3894: Polishing

Remove IPv4 from build.gradle.
Fix race for ackPort.
---
 build.gradle                                                | 4 ----
 .../integration/ip/udp/UnicastSendingMessageHandler.java    | 6 ++++++
 2 files changed, 6 insertions(+), 4 deletions(-)

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 {