test (jkube-kit/remote-dev) : Fix intermittent failures of RemoteDeve…

…lopmentServiceTest

Signed-off-by: Rohan Kumar <rohaan@redhat.com>

.jenkins/pipelines/java-8.Jenkinsfile

@@ -22,7 +22,7 @@ pipeline {
             exit 1
           fi
         '''
-        sh './mvnw -V -B -e  install'
+        sh './mvnw -V -B -e install'
       }
     }
   }

jkube-kit/remote-dev/src/main/java/org/eclipse/jkube/kit/remotedev/RemoteDevelopmentService.java

@@ -16,6 +16,7 @@
 import io.fabric8.kubernetes.client.KubernetesClient;
 import org.eclipse.jkube.kit.common.KitLogger;
 
+import java.net.InetAddress;
 import java.net.ServerSocket;
 import java.util.concurrent.CompletableFuture;
 
@@ -65,7 +66,7 @@ public void stop() {
 
   private void checkEnvironment() {
     for (RemoteService remoteService : context.getRemoteDevelopmentConfig().getRemoteServices()) {
-      try (ServerSocket ignore = new ServerSocket(remoteService.getLocalPort())) {
+      try (ServerSocket ignore = new ServerSocket(remoteService.getLocalPort(), 1, InetAddress.getByName("localhost"))) {
         logger.debug("Local port '%s' for remote service '%s:%s' is available",
           remoteService.getLocalPort(), remoteService.getHostname(), remoteService.getPort());
       } catch (Exception e) {

jkube-kit/remote-dev/src/test/java/org/eclipse/jkube/kit/remotedev/RemoteDevelopmentServiceTest.java

@@ -23,9 +23,12 @@
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 
+import java.net.InetAddress;
 import java.net.ServerSocket;
+import java.net.Socket;
 
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
 import static org.mockito.Mockito.spy;
 import static org.mockito.Mockito.timeout;
 import static org.mockito.Mockito.times;
@@ -118,9 +121,17 @@ void startFailsIfLocalPortInUse() {
     remoteDevelopmentService = new RemoteDevelopmentService(
       logger, kubernetesClient, RemoteDevelopmentConfig.builder().remoteService(remoteService).build());
     assertThatThrownBy(() -> {
-      try (ServerSocket localPortInUse = new ServerSocket(localPort)) {
+      try (ServerSocket localPortInUse = new ServerSocket(localPort, 1, InetAddress.getByName("localhost"))) {
         // When
-        remoteDevelopmentService.start();
+        System.out.println(localPortInUse.getInetAddress().getHostAddress());
+        System.out.println(localPortInUse.getLocalPort());
+        try (Socket socket = new Socket("localhost", localPort)) {
+          System.out.println(socket.getInetAddress().getHostAddress());
+          System.out.println(socket.getLocalPort());
+          assertThat(socket.isBound()).isTrue();
+          assertThat(socket.isClosed()).isFalse();
+          remoteDevelopmentService.start();
+        }
       }
     })
       .hasMessageContaining("Local port '" + localPort + "' is already in use (remote-host)");