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