Method: Beetle::Client#listen_queues

Defined in:
lib/beetle/client.rb

#listen_queues(*queues, &block) ⇒ Object

start listening to a list of queues (default to all registered queues). runs the given block before entering the eventmachine loop.



234
235
236
237
 
# File 'lib/beetle/client.rb', line 234

def listen_queues(*queues, &block)
  queues = determine_queue_names(queues)
  subscriber.listen_queues(queues, &block)
end