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