module Mafia::Consumer::ClassMethods

Attributes

routing_key[R]

Public Instance Methods

consume(routing_key) click to toggle source
# File lib/mafia/consumer.rb, line 15
def consume(routing_key)
  @routing_key = routing_key
end
get_queue_name() click to toggle source
# File lib/mafia/consumer.rb, line 28
def get_queue_name
  return @queue_name unless @queue_name.nil?
  queue_name = self.name.gsub(/::/, ':')
  queue_name.gsub!(/([^A-Z:])([A-Z])/) { "#{$1}_#{$2}" }
  queue_name.downcase
end
process(routing_key, *args) click to toggle source
# File lib/mafia/consumer.rb, line 19
def process(routing_key, *args)
  new(routing_key).process(*args)
end
queue_name(name) click to toggle source

Explicitly set the queue name

# File lib/mafia/consumer.rb, line 24
def queue_name(name)
  @queue_name = name
end