@Test
public void dontSendingSagaEndMessage() throws Throwable {

  when(sagaStart.autoClose()).thenReturn(false);
  omegaContext = new OmegaContext(idGenerator);
  aspect = new SagaStartAspect(sender, omegaContext);
  aspect.advise(joinPoint, sagaStart);
  assertThat(messages.size(), is(1));
  TxEvent startedEvent = messages.get(0);
  assertThat(startedEvent.globalTxId(), is(globalTxId));
  assertThat(startedEvent.localTxId(), is(globalTxId));
  assertThat(startedEvent.parentTxId(), is(nullValue()));
  assertThat(startedEvent.type(), is(EventType.SagaStartedEvent));
  assertThat(omegaContext.globalTxId(), is(nullValue()));
  assertThat(omegaContext.localTxId(), is(nullValue()));
}