diff options
Diffstat (limited to 'java/client/src/main/java/org/apache/qpid/client/AMQConnection.java')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java index 60f57aaf0e..ad611b217a 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java @@ -538,7 +538,8 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect try { - TransportConnection.getInstance(brokerDetail).connect(_protocolHandler, brokerDetail); + TransportConnection.connect(_protocolHandler,brokerDetail); + // this blocks until the connection has been set up or when an error // has prevented the connection being set up |