Class: Bunny::HeartbeatSender

Inherits:
Object
  • Object
show all
Defined in:
lib/bunny/heartbeat_sender.rb

Overview

Periodically sends heartbeats, keeping track of the last publishing activity.

Instance Method Summary collapse

Constructor Details

#initialize(transport, logger) ⇒ HeartbeatSender

API



16
17
18
19
20
21
22
 
# File 'lib/bunny/heartbeat_sender.rb', line 16

def initialize(transport, logger)
  @transport = transport
  @logger    = logger
  @mutex     = Monitor.new

  @last_activity_time = Bunny::Timestamp.monotonic
end

Instance Method Details

#signal_activity! ⇒ Object 



41
42
43
 
# File 'lib/bunny/heartbeat_sender.rb', line 41

def signal_activity!
  @last_activity_time = Bunny::Timestamp.monotonic
end

#start(period = 30) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/bunny/heartbeat_sender.rb', line 24

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))
    @thread.report_on_exception = false
  end
end

#stop ⇒ Object 



37
38
39
 
# File 'lib/bunny/heartbeat_sender.rb', line 37

def stop
  @mutex.synchronize { @thread.exit }
end