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