Method: ActiveMessaging::Adapters::Jms::Connection#receive_message

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

#receive_message(queue_name = nil, headers = {}) ⇒ Object 



95
96
97
98
99
100
101
102
103
104
105
106
107
 
# File 'lib/activemessaging/adapters/jms.rb', line 95

def receive_message(queue_name=nil, headers={})
  if queue_name.nil?
    @consumers.find do |k, c|
      message = c.receive(1)
      return condition_message(message) unless message.nil?
    end
  else
    consumer = subscribe(queue_name, headers)
    message = consumer.receive(1)
    unsubscribe(queue_name, headers)
    condition_message(message)
  end
end