File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
src/main/java/com/rabbitmq/client/impl Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -741,8 +741,8 @@ private void readFrame(Frame frame) throws IOException {
741741
742742 /** private API */
743743 public void handleHeartbeatFailure () {
744- Exception ex = new MissedHeartbeatException ("Heartbeat missing with heartbeat = " +
745- _heartbeat + " seconds" );
744+ Exception ex = new MissedHeartbeatException ("Detected missed server heartbeats, heartbeat interval: " +
745+ _heartbeat + " seconds, RabbitMQ node hostname: " + this . getHostAddress () );
746746 try {
747747 _exceptionHandler .handleUnexpectedConnectionDriverException (this , ex );
748748 shutdown (null , false , ex , true );
@@ -837,7 +837,7 @@ private void handleSocketTimeout() throws SocketTimeoutException {
837837 // of the heartbeat setting in setHeartbeat above.
838838 if (++_missedHeartbeats > (2 * 4 )) {
839839 throw new MissedHeartbeatException ("Heartbeat missing with heartbeat = " +
840- _heartbeat + " seconds" );
840+ _heartbeat + " seconds, for " + this . getHostAddress () );
841841 }
842842 }
843843
You can’t perform that action at this time.
0 commit comments