Add host description when throwing MissedHeartbeatException

rabbitmq · Mar 10, 2022 · 357226b · 357226b
1 parent 0b7d8f0
commit 357226b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/rabbitmq/client/impl/AMQConnection.java b/src/main/java/com/rabbitmq/client/impl/AMQConnection.java
@@ -742,7 +742,7 @@ private void readFrame(Frame frame) throws IOException {
     /** private API */
     public void handleHeartbeatFailure() {
         Exception ex = new MissedHeartbeatException("Heartbeat missing with heartbeat = " +
-            _heartbeat + " seconds");
+            _heartbeat + " seconds, for " + this.getHostAddress());
         try {
             _exceptionHandler.handleUnexpectedConnectionDriverException(this, ex);
             shutdown(null, false, ex, true);
@@ -837,7 +837,7 @@ private void handleSocketTimeout() throws SocketTimeoutException {
         // of the heartbeat setting in setHeartbeat above.
         if (++_missedHeartbeats > (2 * 4)) {
             throw new MissedHeartbeatException("Heartbeat missing with heartbeat = " +
-                                               _heartbeat + " seconds");
+                                               _heartbeat + " seconds, for " + this.getHostAddress());
         }
     }