Class: Smith::Agent
- Inherits:
-
Object
- Object
- Smith::Agent
- Defined in:
- lib/fake_smith.rb
Class Method Summary collapse
Instance Method Summary collapse
- #acknowledge_start(&blk) ⇒ Object
- #acknowledge_stop(&blk) ⇒ Object
- #get_test_logger ⇒ Object
- #logger ⇒ Object
- #queues ⇒ Object
- #receiver(queue_name, opts = {}, &blk) ⇒ Object
- #run_signal_handlers(sig, handlers) ⇒ Object
- #sender(queue_name, opts = {}, &blk) ⇒ Object
- #setup_control_queue ⇒ Object
- #setup_stats_queue ⇒ Object
- #start_keep_alive ⇒ Object
Class Method Details
.options(opts) ⇒ Object
107 108 |
# File 'lib/fake_smith.rb', line 107 def self.(opts) end |
Instance Method Details
#acknowledge_start(&blk) ⇒ Object
130 131 132 |
# File 'lib/fake_smith.rb', line 130 def acknowledge_start(&blk) blk.call end |
#acknowledge_stop(&blk) ⇒ Object
134 135 136 |
# File 'lib/fake_smith.rb', line 134 def acknowledge_stop(&blk) blk.call end |
#get_test_logger ⇒ Object
148 149 150 |
# File 'lib/fake_smith.rb', line 148 def get_test_logger logger end |
#logger ⇒ Object
144 145 146 |
# File 'lib/fake_smith.rb', line 144 def logger @b06b2bd ||= FakeSmith::Logger.new end |
#queues ⇒ Object
141 142 |
# File 'lib/fake_smith.rb', line 141 def queues end |
#receiver(queue_name, opts = {}, &blk) ⇒ Object
119 120 121 122 123 |
# File 'lib/fake_smith.rb', line 119 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) ⇒ Object
110 111 |
# File 'lib/fake_smith.rb', line 110 def run_signal_handlers(sig, handlers) end |
#sender(queue_name, opts = {}, &blk) ⇒ Object
125 126 127 128 |
# File 'lib/fake_smith.rb', line 125 def sender(queue_name, opts={}, &blk) s = Smith::Messaging::Sender.new(queue_name) blk.call(s) if block_given? end |
#setup_control_queue ⇒ Object
113 114 |
# File 'lib/fake_smith.rb', line 113 def setup_control_queue end |
#setup_stats_queue ⇒ Object
116 117 |
# File 'lib/fake_smith.rb', line 116 def setup_stats_queue end |
#start_keep_alive ⇒ Object
138 139 |
# File 'lib/fake_smith.rb', line 138 def start_keep_alive end |