Module: ActiveMessage::Consumer::ClassMethods

Defined in:
lib/active_message/consumer.rb

Instance Method Summary collapse

Instance Method Details

#consume(*routing_keys) ⇒ Object 



9
10
11
12
 
# 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 ⇒ Object 



18
19
20
21
22
23
 
# 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) ⇒ Object 



29
30
31
 
# 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) ⇒ Object 



14
15
16
 
# File 'lib/active_message/consumer.rb', line 14

def queue_name(name)
  @queue_name = name
end

#routing_keys ⇒ Object 



25
26
27
 
# File 'lib/active_message/consumer.rb', line 25

def routing_keys
  @routing_keys ||= Set.new
end