module Qpid::Proton::Util::Engine

@private

Public Class Methods

receive_message(delivery, msg = nil) click to toggle source

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