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