Module: AMQ::Client::Async::Adapter

Defined in:
lib/sensu/rabbitmq.rb

Instance Method Summary collapse

Instance Method Details

#send_heartbeat ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/sensu/rabbitmq.rb', line 9

def send_heartbeat
  if tcp_connection_established? && !reconnecting?
    if !@handling_skipped_hearbeats && @last_server_heartbeat
      send_frame(Protocol::HeartbeatFrame)
      if @last_server_heartbeat < (Time.now - (self.heartbeat_interval * 2))
        logger.error('detected missing amqp heartbeats')
        self.handle_skipped_hearbeats
      end
    end
  end
end