module ActiveMessage::Consumer::ClassMethods

Public Instance Methods

consume(*routing_keys) click to toggle source
# File lib/active_message/consumer.rb, line 9
def consume(*routing_keys)
  ActiveMessage::Logger.debug "Consumer is consuming #{routing_keys.join(", ")} ...."
  @routing_keys = self.routing_keys.union(routing_keys)
end
get_queue_name() click to toggle source
# File lib/active_message/consumer.rb, line 18
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(delivery_info, properties, payload) click to toggle source
# File lib/active_message/consumer.rb, line 29
def process(delivery_info, properties, payload)
  ActiveMessage::Logger.debug "Please implement this method in your consumer ...."
end
queue_name(name) click to toggle source
# File lib/active_message/consumer.rb, line 14
def queue_name(name)
  @queue_name = name
end
routing_keys() click to toggle source
# File lib/active_message/consumer.rb, line 25
def routing_keys
  @routing_keys ||= Set.new
end