testcontainers#291 oops

bsideup · Feb 22, 2017 · f3545ea · f3545ea
1 parent d6a24c4
commit f3545ea
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/src/main/java/org/rnorth/tcpunixsocketproxy/TcpToNamedPipeSocketProxy.java b/core/src/main/java/org/rnorth/tcpunixsocketproxy/TcpToNamedPipeSocketProxy.java
@@ -31,7 +31,10 @@ public InetSocketAddress start() throws IOException {
                     Socket incomingSocket = listenSocket.accept();
                     log.debug("Accepting incoming connection from {}", incomingSocket.getRemoteSocketAddress());
 
-                    new ProxyThread(incomingSocket, new NamedPipeSocket(null, pipeName));
+                    NamedPipeSocket namedPipeSocket = new NamedPipeSocket(null, pipeName);
+                    namedPipeSocket.connect(null);
+
+                    new ProxyThread(incomingSocket, namedPipeSocket);
                 } catch (IOException ignored) {
                 }
             }