Method: ActiveMessaging::Adapters::Jms::Connection#find_or_create_consumer

Defined in:
lib/activemessaging/adapters/jms.rb

#find_or_create_consumer(queue_name, headers = {}) ⇒ Object 



137
138
139
140
141
142
143
144
145
146
147
148
149
150
 
# File 'lib/activemessaging/adapters/jms.rb', line 137

def find_or_create_consumer queue_name, headers={}
  consumer = @consumers[queue_name]
  if consumer.nil?
    destination = find_or_create_destination queue_name, headers
    if headers.symbolize_keys.has_key? :selector
      consumer = @session.create_consumer destination, headers.symbolize_keys[:selector]
    else
      consumer = @session.create_consumer destination
    end
    
    @consumers[queue_name] = consumer
  end
  consumer
end