Class: Smith::Agent

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

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Agent

Returns a new instance of Agent.



188
189
 
# File 'lib/fake_smith.rb', line 188

def initialize
end

Class Method Details

.options(opts) ⇒ Object 



191
192
 
# File 'lib/fake_smith.rb', line 191

def self.options(opts)
end

Instance Method Details

#acknowledge_start(&blk) ⇒ Object 



213
214
215
 
# File 'lib/fake_smith.rb', line 213

def acknowledge_start(&blk)
  blk.call
end

#acknowledge_stop(&blk) ⇒ Object 



217
218
219
 
# File 'lib/fake_smith.rb', line 217

def acknowledge_stop(&blk)
  blk.call
end

#get_test_logger ⇒ Object 



231
232
233
 
# File 'lib/fake_smith.rb', line 231

def get_test_logger
  logger
end

#logger ⇒ Object 



227
228
229
 
# File 'lib/fake_smith.rb', line 227

def logger
  FakeSmith.logger
end

#queues ⇒ Object 



224
225
 
# File 'lib/fake_smith.rb', line 224

def queues
end

#receiver(queue_name, opts = {}, &blk) ⇒ Object 



203
204
205
206
207
 
# File 'lib/fake_smith.rb', line 203

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 



194
195
 
# File 'lib/fake_smith.rb', line 194

def run_signal_handlers(sig, handlers)
end

#sender(queue_names, opts = {}, &blk) ⇒ Object 



209
210
211
 
# File 'lib/fake_smith.rb', line 209

def sender(queue_names, opts={}, &blk)
  Array(queue_names).each { |queue_name| Smith::Messaging::Sender.new(queue_name, opts, &blk)  }
end

#setup_control_queue ⇒ Object 



197
198
 
# File 'lib/fake_smith.rb', line 197

def setup_control_queue
end

#setup_stats_queue ⇒ Object 



200
201
 
# File 'lib/fake_smith.rb', line 200

def setup_stats_queue
end

#start_keep_alive ⇒ Object 



221
222
 
# File 'lib/fake_smith.rb', line 221

def start_keep_alive
end