Spring Batch SkipListener pas appelé lorsque l'exception se produit dans le lecteur

C'est mon étape de configuration. Mon ignorer les auditeurs onSkipInWrite() la méthode est appelée correctement. Mais onSkipInRead() n'est pas appelé. J'ai trouvé cette délibérément lancer une exception de pointeur null à partir de mon lecteur.

<step id="callService" next="writeUsersAndResources">
        <tasklet allow-start-if-complete="true">
            <chunk reader="Reader" writer="Writer"
                commit-interval="10" skip-limit="10">
                <skippable-exception-classes>
                    <include class="java.lang.Exception" />
                </skippable-exception-classes>
            </chunk>
            <listeners>
                <listener ref="skipListener" />
            </listeners>
        </tasklet>
    </step>

J'ai lu quelques forums et interchangeables, les auditeurs-tag à deux niveaux: à l'Intérieur du bloc, et à l'extérieur de la tasklet. Rien ne fonctionne...

L'ajout de mon ignorer Écouteur ici

package com.legal.batch.core;

import org.apache.commons.lang.StringEscapeUtils;
import org.springframework.batch.core.SkipListener;
import org.springframework.jdbc.core.JdbcTemplate;


public class SkipListener implements SkipListener<Object, Object> {


    @Override
    public void onSkipInProcess(Object arg0, Throwable arg1) {
        //TODO Auto-generated method stub

    }

    @Override
    public void onSkipInRead(Throwable arg0) {
    }

    @Override
    public void onSkipInWrite(Object arg0, Throwable arg1) {
}

}

Experts s'il vous plaît suggérer

vous pouvez également poster votre "skipListener" de la fève de configuration et de mise en œuvre? Êtes-vous à la mise en œuvre de SkipListener<T,S> interface? Êtes-vous à l'aide de @OnSkipInRead annotation? etc..
Ajouté le branchement écouteur ici

OriginalL'auteur Shiva | 2011-10-03

  1. 12

    Sauter des auditeurs à l'égard de la transaction limite, ce qui signifie qu'ils ont toujours appelé juste avant la transaction est validée.

    Depuis un intervalle de validation dans votre exemple est réglé sur "10", le onSkipInRead sera appelée au moment de commettre ces 10 éléments (à la fois).

    Donc, si vous essayez de faire une étape par étape de débogage, vous ne verriez pas un onSkipInRead appelé immédiatement après un ItemReader déclenche une exception.

    Un SkipListener dans votre exemple a un vide onSkipInRead méthode. Essayez d'ajouter quelques traces à l'intérieur de onSkipInRead, déplacer et exécuter de nouveau votre travail pour voir ces messages.

    MODIFIER:

    Voici un exemple de travail [noms sont changés à "abc"]:

    <step id="abcStep" xmlns="http://www.springframework.org/schema/batch">
    <tasklet>
        <chunk writer="abcWriter"
               reader="abcReader"
               commit-interval="${abc.commit.interval}"
               skip-limit="1000" >

            <skippable-exception-classes>
                <include class="com.abc....persistence.mapping.exception.AbcMappingException"/>
                <include class="org.springframework.batch.item.validator.ValidationException"/>
                ...
                <include class="...Exception"/>
            </skippable-exception-classes>

            <listeners>
                <listener ref="abcSkipListener"/>
            </listeners>

        </chunk>

        <listeners>
            <listener ref="abcStepListener"/>
            <listener ref="afterStepStatsListener"/>
        </listeners>

        <no-rollback-exception-classes>
            <include class="com.abc....persistence.mapping.exception.AbcMappingException"/>
            <include class="org.springframework.batch.item.validator.ValidationException"/>
            ...
            <include class="...Exception"/> 
        </no-rollback-exception-classes>

        <transaction-attributes isolation="READ_COMMITTED"
                                propagation="REQUIRED"/>
    </tasklet>
</step>

    où un abcSkipListener bean est:

    public class AbcSkipListener {

    private static final Logger logger = LoggerFactory.getLogger( "abc-skip-listener" );

    @OnReadError
    public void houstonWeHaveAProblemOnRead( Exception problem ) {
        //...
    }


    @OnSkipInWrite
    public void houstonWeHaveAProblemOnWrite( AbcHolder abcHolder, Throwable problem ) {
        //...
    }

    ....
}
    Merci.. j'ai eu sysout code à l'intérieur de onSkipInRead(). De plus, je suis jeter de nouvelles nullPointerException à partir de la première ligne de mon lecteur.J'ai vu dans le journal que sauter la limite de 10 a été dépassé et puis m'attendais à le sysout dans mon saut de lecture à imprimer. Mais ne pas le voir. J'ai essayer de mettre les auditeurs en dehors de la tasklet. Pas de chance..
    voici un exemple de travail de l'un de mes projets dans le passé. Essayez d'utiliser @OnReadError dans une benne à l'écoute.
    je vous remercie. obtenez de retour..

    OriginalL'auteur tolitius