Method: RosettaQueue::Gateway::StompAdapter#receive_once

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

#receive_once(destination, opts) ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/rosetta_queue/adapters/stomp.rb', line 27

def receive_once(destination, opts)
  subscribe(destination, opts)
  msg = receive(opts).body
  unsubscribe(destination)
  RosettaQueue.logger.info("Receiving from #{destination} :: #{msg}")
  filter_receiving(msg)
end