@Test
void failureProcessingItemShouldRollback() {

    // given
    doThrow(ParserSQLException.class).when(recordItemListener).onItem(any());
    // when
    Assertions.assertThrows(IllegalArgumentException.class, () -> {
        recordFileParser.parse(streamFileData1);
    });
    // then
    verify(recordStreamFileListener).onStart(streamFileData1);
    verify(recordStreamFileListener, never()).onEnd(recordFile1);
    verify(recordStreamFileListener).onError();
}