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