code: private KeyReader tryGetKeyReader(final Class<? extends Saga> sagaClazz, final Object message) {
          KeyReader reader;
  
          try {
              Optional<KeyReader> cachedReader = knownReaders.get(
                      SagaMessageKey.forMessage(sagaClazz, message),
                      () -> {
                          KeyReader foundReader = findReader(sagaClazz, message);
                          return Optional.fromNullable(foundReader);
                      });
              reader = cachedReader.orNull();
          } catch (Exception ex) {
              LOG.error("Error searching for reader to extract saga key. sagatype = {}, message = {}", sagaClazz, message, ex);
              reader = null;
          }
  
          return reader;
      }
docs: Does not throw an exception when accessing the loading cache for key readers.