File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/main/java/com/rabbitmq/client/impl Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -742,7 +742,7 @@ private void readFrame(Frame frame) throws IOException {
742
742
/** private API */
743
743
public void handleHeartbeatFailure () {
744
744
Exception ex = new MissedHeartbeatException ("Heartbeat missing with heartbeat = " +
745
- _heartbeat + " seconds" );
745
+ _heartbeat + " seconds, for " + this . getHostAddress () );
746
746
try {
747
747
_exceptionHandler .handleUnexpectedConnectionDriverException (this , ex );
748
748
shutdown (null , false , ex , true );
@@ -837,7 +837,7 @@ private void handleSocketTimeout() throws SocketTimeoutException {
837
837
// of the heartbeat setting in setHeartbeat above.
838
838
if (++_missedHeartbeats > (2 * 4 )) {
839
839
throw new MissedHeartbeatException ("Heartbeat missing with heartbeat = " +
840
- _heartbeat + " seconds" );
840
+ _heartbeat + " seconds, for " + this . getHostAddress () );
841
841
}
842
842
}
843
843
You can’t perform that action at this time.
0 commit comments