Method: ActiveMessaging::Adapters::Jms::Connection#subscribe

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

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



49
50
51
52
# File 'lib/activemessaging/adapters/jms.rb', line 49

def subscribe queue_name, headers={}
  queue_name = check_destination_type queue_name, headers
  find_or_create_consumer queue_name, headers
end