Skip to content

Commit 51edd93

Browse files
author
Steve Powell
committed
Correct heartbeat shutdown
1 parent 19a876e commit 51edd93

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/com/rabbitmq/client/impl/AMQConnection.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -376,11 +376,11 @@ public void start()
376376
.virtualHost(_virtualHost)
377377
.build());
378378
} catch (IOException ioe) {
379-
setHeartbeat(0);
379+
_heartbeatSender.shutdown();
380380
_frameHandler.close();
381381
throw ioe;
382382
} catch (ShutdownSignalException sse) {
383-
setHeartbeat(0);
383+
_heartbeatSender.shutdown();
384384
_frameHandler.close();
385385
throw AMQChannel.wrap(sse);
386386
}

0 commit comments

Comments
 (0)