@Test
public void test_split() {

    createAndSaveMessages(2, (message, order) -> {
        switch (order) {
            case 1:
                message.setState(MsgStateEnum.OK);
                message.setLastUpdateTimestamp(Instant.now().minusSeconds(okSaveTimeInSec + 1));
                break;
            case 2:
                message.setState(MsgStateEnum.FAILED);
                message.setLastUpdateTimestamp(Instant.now().minusSeconds(failedSaveTimeInSec + 1));
                break;
        }
    });
    messagesProcessingService.processMessages();
    verify(finalMessageProcessor, times(2)).processMessage(any(Message.class));
    verify(additionalMessageProcessor, times(2)).processMessage(any(Message.class));
}