diff --git a/core/src/main/java/org/rnorth/tcpunixsocketproxy/TcpToNamedPipeSocketProxy.java b/core/src/main/java/org/rnorth/tcpunixsocketproxy/TcpToNamedPipeSocketProxy.java
index 226a77245d0..133b2c69f5e 100644
--- 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) {
                 }
             }