class Protobuf::Rpc::Connectors::Zmq
def create_socket
service. The LINGER is set to 0 so we can close immediately in
Create a socket connected to a server that can handle the current
def create_socket begin socket = zmq_context.socket(::ZMQ::REQ) if socket # Make sure the context builds the socket server_uri = lookup_server_uri socket.setsockopt(::ZMQ::LINGER, 0) zmq_error_check(socket.connect(server_uri), :socket_connect) socket = socket_to_available_server(socket) if first_alive_load_balance? end end while socket.try(:socket).nil? socket end