class Smith::Agent
Public Class Methods
new()
click to toggle source
# File lib/fake_smith.rb, line 189 def initialize end
options(opts)
click to toggle source
# File lib/fake_smith.rb, line 192 def self.options(opts) end
Public Instance Methods
acknowledge_start(&blk)
click to toggle source
# File lib/fake_smith.rb, line 214 def acknowledge_start(&blk) blk.call end
acknowledge_stop(&blk)
click to toggle source
# File lib/fake_smith.rb, line 218 def acknowledge_stop(&blk) blk.call end
get_test_logger()
click to toggle source
# File lib/fake_smith.rb, line 232 def get_test_logger logger end
logger()
click to toggle source
# File lib/fake_smith.rb, line 228 def logger FakeSmith.logger end
queues()
click to toggle source
# File lib/fake_smith.rb, line 225 def queues end
receiver(queue_name, opts={}, &blk)
click to toggle source
# File lib/fake_smith.rb, line 204 def receiver(queue_name, opts={}, &blk) r = Smith::Messaging::Receiver.new(queue_name, opts, &blk) blk.call r if block_given? r end
run_signal_handlers(sig, handlers)
click to toggle source
# File lib/fake_smith.rb, line 195 def run_signal_handlers(sig, handlers) end
sender(queue_names, opts={}, &blk)
click to toggle source
# File lib/fake_smith.rb, line 210 def sender(queue_names, opts={}, &blk) Array(queue_names).each { |queue_name| Smith::Messaging::Sender.new(queue_name, opts, &blk) } end
setup_control_queue()
click to toggle source
# File lib/fake_smith.rb, line 198 def setup_control_queue end
setup_stats_queue()
click to toggle source
# File lib/fake_smith.rb, line 201 def setup_stats_queue end
start_keep_alive()
click to toggle source
# File lib/fake_smith.rb, line 222 def start_keep_alive end