diff --git a/src/lavinmq/amqp/client.cr b/src/lavinmq/amqp/client.cr
index 08c948256..0fa5366d6 100644
--- a/src/lavinmq/amqp/client.cr
+++ b/src/lavinmq/amqp/client.cr
@@ -141,12 +141,14 @@ module LavinMQ
         rescue ex : AMQP::Error::FrameDecode
           @log.error { ex.inspect_with_backtrace }
           send_frame_error(ex.message)
+          break
         rescue ex : IO::Error | OpenSSL::SSL::Error
           @log.debug { "Lost connection, while reading (#{ex.inspect})" } unless closed?
           break
         rescue ex : Exception
           @log.error { "Unexpected error, while reading: #{ex.inspect_with_backtrace}" }
           send_internal_error(ex.message)
+          break
         end
       ensure
         cleanup