Closed paneq closed 11 years ago
Handle ZMQ errors somehow
def receive @request_socket.recv_string(msg = "") @request_parser.parse(msg) end def deliver(uuid, connection_ids, data) msg = "#{uuid} #{TNetstring.dump([*connection_ids].join(' '))} #{data}" @response_socket.send_string(msg) end
Handle ZMQ errors somehow