public Map sagaTasks()

in saga-core/src/main/java/org/apache/servicecomb/saga/core/SagaTaskFactory.java [39:54]

• 13 lines of code
• 1 McCabe index (conditional complexity)

  public Map<String, SagaTask> sagaTasks(final String sagaId,
      final String requestJson,
      final RecoveryPolicy recoveryPolicy,
      final EventStore sagaLog) {

    final SagaLog compositeSagaLog = compositeSagaLog(sagaLog, persistentStore);

    return new HashMap<String, SagaTask>() {{
      put(SagaTask.SAGA_START_TASK, new SagaStartTask(sagaId, requestJson, compositeSagaLog));

      SagaLog retrySagaLog = compositeSagaLog(sagaLog, SagaTaskFactory.this.retrySagaLog);
      put(SagaTask.SAGA_REQUEST_TASK,
          new RequestProcessTask(sagaId, retrySagaLog, new LoggingRecoveryPolicy(recoveryPolicy), fallbackPolicy));
      put(SagaTask.SAGA_END_TASK, new SagaEndTask(sagaId, retrySagaLog));
    }};
  }