lib/amq/client/async/adapters/event_machine.rb in amq-client-0.9.8 vs lib/amq/client/async/adapters/event_machine.rb in amq-client-0.9.9
- old
+ new
@@ -265,10 +265,10 @@
@had_successfully_connected_before = true
@reconnecting = false
@handling_skipped_hearbeats = false
@last_server_heartbeat = Time.now
- self.initialize_heartbeat_sender if self.heartbeat_interval > 0
+ self.initialize_heartbeat_sender if heartbeats_enabled?
self.handshake
end
# @private