public void reanimate()

in saga-core/src/main/java/org/apache/servicecomb/saga/core/application/SagaExecutionComponent.java [66:82]

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

  public void reanimate() {
    Map<String, List<EventEnvelope>> pendingSagaEvents = persistentStore.findPendingSagaEvents();

    for (Entry<String, List<EventEnvelope>> entry : pendingSagaEvents.entrySet()) {
      EventStore eventStore = new EmbeddedEventStore();
      eventStore.populate(entry.getValue());
      SagaEvent event = entry.getValue().iterator().next().event;

      String requestJson = event.json(toJsonFormat);
      SagaDefinition definition = fromJsonFormat.fromJson(requestJson);

      Saga saga = sagaFactory.createSaga(requestJson, event.sagaId, eventStore, definition);

      saga.play();
      saga.run();
    }
  }