public void run()

in modules/core/src/main/java/org/apache/fluo/core/client/LoaderExecutorAsyncImpl.java [126:157]

• 28 lines of code
• 4 McCabe index (conditional complexity)

    public void run() {
      txi = new TransactionImpl(env);

      if (TracingTransaction.isTracingEnabled()) {
        txi = new TracingTransaction(txi, loader.getClass(), identity);
      }

      Loader.Context context = new Loader.Context() {
        @Override
        public SimpleConfiguration getAppConfiguration() {
          return env.getAppConfiguration();
        }

        @Override
        public MetricsReporter getMetricsReporter() {
          return env.getMetricsReporter();
        }
      };

      try {
        loader.load(txi, context);
        env.getSharedResources().getCommitManager().beginCommit(txi, identity, this);
      } catch (Exception e) {
        if (future == null) {
          setException(e);
        } else {
          future.completeExceptionally(e);
        }
        close();
        LoggerFactory.getLogger(LoaderCommitObserver.class).debug(e.getMessage(), e);
      }
    }