Method: RosettaQueue::Gateway::StompAdapter#receive

Defined in:
lib/rosetta_queue/adapters/stomp.rb

#receive(options) ⇒ Object 



21
22
23
24
25
 
# File 'lib/rosetta_queue/adapters/stomp.rb', line 21

def receive(options)
  msg = @conn.receive
  ack(msg) unless options[:ack].nil?
  msg
end