lib/amq/client/async/adapters/coolio.rb in amq-client-0.8.1 vs lib/amq/client/async/adapters/coolio.rb in amq-client-0.8.2

- old
+ new

@@ -272,10 +272,15 @@ # @api private def self.tcp_connection_failure_exception_class AMQ::Client::TCPConnectionFailed end # self.tcp_connection_failure_exception_class + def handle_skipped_hearbeats + # TODO + end + + protected # @api private def post_init if @had_successfully_connected_before @@ -289,10 +294,11 @@ end end # now we can set it. MK. @had_successfully_connected_before = true - @reconnecting = false + @reconnecting = false + @handling_skipped_hearbeats = false self.reset self.handshake end