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
109 110 |
# File 'lib/fake_smith.rb', line 109 def self.(opts) end |
Instance Method Details
#acknowledge_start(&blk) ⇒ Object
132 133 134 |
# File 'lib/fake_smith.rb', line 132 def acknowledge_start(&blk) blk.call end |
#acknowledge_stop(&blk) ⇒ Object
136 137 138 |
# File 'lib/fake_smith.rb', line 136 def acknowledge_stop(&blk) blk.call end |
#get_test_logger ⇒ Object
150 151 152 |
# File 'lib/fake_smith.rb', line 150 def get_test_logger logger end |
#logger ⇒ Object
146 147 148 |
# File 'lib/fake_smith.rb', line 146 def logger @b06b2bd ||= FakeSmith::Logger.new end |
#queues ⇒ Object
143 144 |
# File 'lib/fake_smith.rb', line 143 def queues end |
#receiver(queue_name, opts = {}, &blk) ⇒ Object
121 122 123 124 125 |
# File 'lib/fake_smith.rb', line 121 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
112 113 |
# File 'lib/fake_smith.rb', line 112 def run_signal_handlers(sig, handlers) end |
#sender(queue_name, opts = {}, &blk) ⇒ Object
127 128 129 130 |
# File 'lib/fake_smith.rb', line 127 def sender(queue_name, opts={}, &blk) s = Smith::Messaging::Sender.new(queue_name) blk.call(s) if block_given? end |
#setup_control_queue ⇒ Object
115 116 |
# File 'lib/fake_smith.rb', line 115 def setup_control_queue end |
#setup_stats_queue ⇒ Object
118 119 |
# File 'lib/fake_smith.rb', line 118 def setup_stats_queue end |
#start_keep_alive ⇒ Object
140 141 |
# File 'lib/fake_smith.rb', line 140 def start_keep_alive end |