Stop heartbeat after socket was closed

ba-st · Aug 30, 2024 · 478e3bb · 478e3bb
1 parent 654f411
commit 478e3bb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/source/Ansible-Protocol-Core/AmqpConnection.class.st b/source/Ansible-Protocol-Core/AmqpConnection.class.st
@@ -50,15 +50,15 @@ AmqpConnection >> becomeCloseAfter: aBlock [
           LogRecord emitInfo: ( 'AMQP connection <1s> closed due to <2s>'
                 expandMacrosWith: self connectionPairsDescription
                 with: closingMethod replyText ).
-          heartbeatSender stop.
           [ socket close ]
             on: ExpectedSocketFailure
             do: [ :error | 
 					" If the socket was unexpectedly closed, trying to close it again 
 					will raise a SocketError that we want to silence "
 					error return ].
           isOpen := false.
-          socketConnectionStatus := ClosedSocketConnection dueTo: closingMethod replyText
+          socketConnectionStatus := ClosedSocketConnection dueTo: closingMethod replyText.
+          heartbeatSender stop.
         ]
     ]
 ]