docs: protected void process(T input) {
          try {
              Optional.ofNullable(this.transformFunction.apply(input))
                      .ifPresent(this.outputPublisher::submit);
          } catch (Exception e) {
              JMExceptionManager.handleException(log, e, "process", input);
          }
      }