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