@Test
public void blowsUpWhenEventIsSagaStarted() {

  TxEvent event = new SagaStartedEvent(globalTxId, localTxId, 0);
  try {
    messageSender.send(event);
    expectFailing(OmegaException.class);
  } catch (OmegaException e) {
    assertThat(e.getMessage(),
        is("Failed to process subsequent requests because no alpha server is available"));
  }
}