@Test
public void persistEventOnArrival() throws Exception {

  TxEvent[] events = {
      newEvent(SagaStartedEvent),
      newEvent(TxStartedEvent),
      newEvent(TxEndedEvent),
      newEvent(TxCompensatedEvent),
      newEvent(SagaEndedEvent)};
  for (TxEvent event : events) {
    consistentService.handle(event);
  }
  assertThat(this.events, contains(events));
}