Periodically sends heartbeats, keeping track of the last publishing activity.
@private
# File lib/bunny/heartbeat_sender.rb, line 39 def signal_activity! @last_activity_time = Time.now end
# File lib/bunny/heartbeat_sender.rb, line 23 def start(period = 30) @mutex.synchronize do # calculate interval as half the given period plus # some compensation for Ruby's implementation inaccuracy # (we cannot get at the nanos level the Java client uses, and # our approach is simplistic). MK. @interval = [(period / 2) - 1, 0.4].max @thread = Thread.new(&method(:run)) end end
# File lib/bunny/heartbeat_sender.rb, line 61 def beat now = Time.now if now > (@last_activity_time + @interval) @logger.debug "Sending a heartbeat, last activity time: #{@last_activity_time}, interval (s): #{@interval}" @transport.write_without_timeout(AMQ::Protocol::HeartbeatFrame.encode) end end
# File lib/bunny/heartbeat_sender.rb, line 45 def run begin loop do self.beat sleep @interval end rescue IOError => ioe @logger.error "I/O error in the hearbeat sender: #{ioe.message}" stop rescue Exception => e @logger.error "Error in the hearbeat sender: #{e.message}" stop end end
Generated with the Darkfish Rdoc Generator 2.