# File lib/util/engine.rb, line 32 def self.receive_message(delivery, msg = nil) msg = Qpid::Proton::Message.new if msg.nil? msg.decode(delivery.link.receive(delivery.pending)) delivery.link.advance return msg end