@Test
public void testOnFailedDeletesExecutionStates() {

	List<ExecutionMessage> messages = new ArrayList<>();
	messages.add(createExecutionMessage());
	messages.add(createExecutionMessage());
	queueListener.onFailed(messages);
	verify(executionStateService, times(1)).deleteExecutionState(Long.valueOf(messages.get(0).getMsgId()), ExecutionSummary.EMPTY_BRANCH);
	verify(executionStateService, times(1)).deleteExecutionState(Long.valueOf(messages.get(1).getMsgId()), ExecutionSummary.EMPTY_BRANCH);
}