diff --git a/src/java/org/jivesoftware/multiplexer/ConnectionWorkerThread.java b/src/java/org/jivesoftware/multiplexer/ConnectionWorkerThread.java
index 51cc13d..d7b1f94 100644
--- a/src/java/org/jivesoftware/multiplexer/ConnectionWorkerThread.java
+++ b/src/java/org/jivesoftware/multiplexer/ConnectionWorkerThread.java
@@ -153,7 +153,7 @@
                     // Establish a TCP connection to the Receiving Server
                     socket.connect(new InetSocketAddress(realHostname, port), 20000);
                     Log.debug("CM - Plain connection to " + serverName + ":" + port + " successful");
-                    return true;
+                    break;
                 }
                 catch (Exception e) {
                     Log.error("Error trying to connect to server: " + serverName +