ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParsePayload.java [117:125]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        message = PubsubConstraints.ensureNonNull(message);
        Map<String, String> attributes = new HashMap<>(message.getAttributeMap());

        final int submissionBytes = message.getPayload().length;

        ObjectNode json;
        try {
          json = parseTimed(message.getPayload());
        } catch (IOException e) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ipprivacy/ExtractClientIdAndDropPayload.java [46:54]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
          message = PubsubConstraints.ensureNonNull(message);
          Map<String, String> attributes = new HashMap<>(message.getAttributeMap());

          final int submissionBytes = message.getPayload().length;

          ObjectNode json;
          try {
            json = parseTimed(message.getPayload());
          } catch (IOException e) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -