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);
}
}
}