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.



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

def initialize
end

Class Method Details

.options(opts) ⇒ Object 



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

def self.options(opts)
end

Instance Method Details

#acknowledge_start(&blk) ⇒ Object 



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

def acknowledge_start(&blk)
  blk.call
end

#acknowledge_stop(&blk) ⇒ Object 



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

def acknowledge_stop(&blk)
  blk.call
end

#get_test_logger ⇒ Object 



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

def get_test_logger
  logger
end

#logger ⇒ Object 



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

def logger
  FakeSmith.logger
end

#queues ⇒ Object 



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

def queues
end

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



204
205
206
207
208
 
# 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) ⇒ Object 



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

def run_signal_handlers(sig, handlers)
end

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



210
211
212
 
# 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 ⇒ Object 



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

def setup_control_queue
end

#setup_stats_queue ⇒ Object 



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

def setup_stats_queue
end

#start_keep_alive ⇒ Object 



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

def start_keep_alive
end