class AmqpUtils::MessageFormatter::Message

Public Instance Methods

generate(io, header, message) click to toggle source
# File lib/amqp_utils/message_formatter.rb, line 56
def generate(io, header, message)
  io.puts message
end
load(io) click to toggle source
# File lib/amqp_utils/message_formatter.rb, line 60
def load(io)
  msg = io.gets
  msg ? { 'message' => msg } : nil
end