@Test
public void blowsUpWhenInterrupted() throws InterruptedException {

  Thread thread = new Thread( new Runnable() {
    @Override
    public void run() {
      try {
        messageSender.send(event);
        expectFailing(OmegaException.class);
      } catch (OmegaException e) {
        assertThat(e.getMessage().endsWith("interruption"), is(true));
      }
    }
  });
  thread.start();
  thread.interrupt();
  thread.join();
}