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