class Protobuf::Rpc::Connectors::Zmq

def connect_to_rpc_server


asked to close/terminate.
for queued messages to be accepted when the socket/context are
Set the socket option LINGER to 0 so that we don't wait
Establish a request socket connection to the remote rpc_server. 
def connect_to_rpc_server
  return if error?
  server_uri = lookup_server_uri
  log_debug { sign_message("Establishing connection: #{server_uri}") }
  socket.setsockopt(::ZMQ::LINGER, 0)
  zmq_error_check(socket.connect(server_uri), :socket_connect)
  zmq_error_check(poller.register_readable(socket), :poller_register_readable)
  log_debug { sign_message("Connection established to #{server_uri}") }
end