@Test
public void skipSagaEndedEvent_IfGlobalTxAlreadyFailed() {

  String localTxId1 = UUID.randomUUID().toString();
  events.add(eventOf(SagaStartedEvent, localTxId1));
  events.add(eventOf(TxAbortedEvent, localTxId1));
  TxEvent event = eventOf(SagaEndedEvent, localTxId1);
  consistentService.handle(event);
  assertThat(events.size(), is(2));
}