@Test
public void testOnFailedBranchExecution() {

	List<ExecutionMessage> messages = new ArrayList<>();
	Execution execution1 = createBranchExecution();
	Execution execution2 = createBranchExecution();
	messages.add(createExecutionMessage(execution1));
	messages.add(createExecutionMessage(execution2));
	queueListener.onFailed(messages);
	verify(splitJoinService, times(1)).endBranch((List<Execution>) argThat(hasItem(execution1)));
	verify(splitJoinService, times(1)).endBranch((List<Execution>) argThat(hasItem(execution2)));
}