class AMQP::Session

Public Instance Methods

send_heartbeat() click to toggle source
# File lib/sensu/transport/patches/amqp.rb, line 3
def send_heartbeat
  if tcp_connection_established? && !reconnecting? && !closed?
    send_frame(AMQ::Protocol::HeartbeatFrame)
    if !@handling_skipped_heartbeats && @last_server_heartbeat
      if @last_server_heartbeat < (Time.now - (self.heartbeat_interval * 2))
        logger.error("[amqp] Detected missing amqp heartbeats")
        self.handle_skipped_heartbeats
      end
    end
  end
end