@Test
public void shouldThrowRuntimeException() throws Exception {

  final IOException exception = new IOException();
  doThrow(exception).when(storage).runInTransactionWithRetries(any());
  try {
    stateManager.receive(Event.dequeue(INSTANCE, ImmutableSet.of()));
    fail();
  } catch (Exception e) {
    assertThat(Throwables.getRootCause(e), is(exception));
  }
}