@private
Convenience method to receive messages from a delivery.
@param delivery [Qpid::Proton::Delivery] The delivery. @param msg [Qpid::Proton::Message] The message to use.
@return [Qpid::Proton::Message] the message
# 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