ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParseUri.java [173:182]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        .exceptionsInto(TypeDescriptor.of(PubsubMessage.class))
        .exceptionsVia((WithFailures.ExceptionElement<PubsubMessage> ee) -> {
          try {
            throw ee.exception();
          } catch (UncheckedIOException | InvalidUriException | MessageScrubberException e) {
            return FailureMessage.of(ParseUri.class.getSimpleName(), //
                ee.element(), //
                ee.exception());
          }
        });
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParseUri.java [197:206]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        .exceptionsInto(TypeDescriptor.of(PubsubMessage.class))
        .exceptionsVia((WithFailures.ExceptionElement<PubsubMessage> ee) -> {
          try {
            throw ee.exception();
          } catch (UncheckedIOException | InvalidUriException | MessageScrubberException e) {
            return FailureMessage.of(ParseUri.class.getSimpleName(), //
                ee.element(), //
                ee.exception());
          }
        });
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -