module AgentZMQ::Helpers

Public Instance Methods

publish(socket, msg) click to toggle source
# File lib/agent_zmq/helpers.rb, line 17
def publish socket, msg
  msg = [msg] unless msg.is_a? Array

  while true do
    msg_part=msg.shift

    if msg.empty?
      socket.send_string msg_part
      break
    else
      socket.send_string msg_part, ZMQ::SNDMORE
    end
  end
end
read_msg(socket) click to toggle source
# File lib/agent_zmq/helpers.rb, line 5
def read_msg socket
  msg_parts = []

  begin
    part=""
    socket.recv_string part
    msg_parts << part
  end while socket.more_parts?

  msg_parts
end