@Test
public void shouldNotThrowIfStateChangeFailsInDatabase() throws Exception {

    doThrow(new RuntimeException("Unexpected disturbance in the force")).when(jobServiceMock).stopJob(JOB_ID);
    subject.consumeStateChange(stateChangedEvent(STOP));
    verify(jobServiceMock).stopJob(JOB_ID);
}