class Protobuf::Rpc::Connectors::Zmq

def connect_to_rpc_server
  return if @error
  log_debug { sign_message("Establishing connection: #{options[:host]}:#{options[:port]}") }
  @zmq_context = ::ZMQ::Context.new
  @socket = @zmq_context.socket(::ZMQ::REQ)
  zmq_error_check(@socket.connect("tcp://#{options[:host]}:#{options[:port]}"))
  log_debug { sign_message("Connection established #{options[:host]}:#{options[:port]}") }
end