static void processPayload()

in client/src/main/java/com/google/cloud/solutions/opencensus/client/TestInstrumentation.java [178:195]


  static void processPayload(byte[] payload, Function<Integer[], Integer> fn, String fnName) {
    String jsonString = new String(payload, StandardCharsets.UTF_8);
    try {
      JSONObject obj = new JSONObject(jsonString);
      JSONArray numArray = obj.getJSONArray("numbers");
      Integer[] num = new Integer[numArray.length()];
      for (int i = 0; i < numArray.length(); i++) {
        num[i] = numArray.optInt(i);
      }
      int result = fn.apply(num);
      LOGGER.info("Processing result " + result + " (" + fnName + ")");
    } catch (JSONException e) {
      LOGGER.log(Level.WARNING, "Exception parsing payload " + e.getMessage());
      if (payload.length < 1000) {
        LOGGER.info("jsonString: " + jsonString);
      }
    }
  }