commit 83dd606e3ce9e035f551f004ada071336f3efb65
author Lorenz Quack <lquack@apache.org> Wed Nov 08 16:34:17 2017 +0000
committer Lorenz Quack <lquack@apache.org> Wed Nov 08 16:34:17 2017 +0000
tree 077815659fd496edb2092a02425f3beb3cecbfbc
parent ffa282d5e582363a103f5337c490d9f2ec602f91

QPID-8018: [Java Client, AMQP 0-x] Clarify error message when connection times out.

client/src/main/java/org/apache/qpid/client/util/BlockingWaiter.java

diff --git a/client/src/main/java/org/apache/qpid/client/util/BlockingWaiter.java b/client/src/main/java/org/apache/qpid/client/util/BlockingWaiter.java
index c3ba234..c977854 100644
--- a/client/src/main/java/org/apache/qpid/client/util/BlockingWaiter.java
+++ b/client/src/main/java/org/apache/qpid/client/util/BlockingWaiter.java
@@ -28,8 +28,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import org.apache.qpid.QpidException;
 import org.apache.qpid.AMQTimeoutException;
+import org.apache.qpid.QpidException;
 import org.apache.qpid.client.failover.FailoverException;
 
 /**
@@ -167,7 +167,11 @@
 
                         if (nanoTimeout <= 0 && !_ready && _error == null)
                         {
-                            _error = new AMQTimeoutException("Server did not respond in a timely fashion", null);
+                            final String errorMsg = String.format(
+                                    "Waiting for receive timed out after %d ms. Possible reasons include JVM garbage"
+                                    + " collection, slow connection, busy broker, ...",
+                                    timeout);
+                            _error = new AMQTimeoutException(errorMsg, null);
                             _ready = true;
                         }
                     }