@Test
public void skipTxStartedEvent_IfGlobalTxAlreadyFailed() {

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