# File lib/amqp/client.rb, line 61 def init_heartbeat @last_server_heartbeat = Time.now @timer ||= EM::PeriodicTimer.new(@settings[:heartbeat]) do if connected? if @last_server_heartbeat < (Time.now - (@settings[:heartbeat] * 2)) log "Reconnecting due to missing server heartbeats" reconnect(true) else send AMQP::Frame::Heartbeat.new end end end end