class Pantry::Communication::SerializeMessage::ToZeromq

Public Class Methods

new(message) click to toggle source
# File lib/pantry/communication/serialize_message.rb, line 29
def initialize(message)
  @message = message
end

Public Instance Methods

perform() click to toggle source
# File lib/pantry/communication/serialize_message.rb, line 33
def perform
  [
    @message.to || "",
    @message.metadata.to_json,
    encode_message_body
  ].flatten.compact
end

Protected Instance Methods

encode_message_body() click to toggle source
# File lib/pantry/communication/serialize_message.rb, line 43
def encode_message_body
  @message.body.map do |entry|
    case entry
    when Hash, Array
      "#{IS_JSON}#{entry.to_json}"
    else
      entry.to_s
    end
  end
end