3 Replies Latest reply on Feb 15, 2018 11:16 AM by Cheng Fang

    ItemProcessor skip record

    Richard Moore Master

      Is there a way to throw an exception in the ItemProcessor and have it trigger the SkipReadListener? I want to write out unreadable records and records that cannot be reformatted written to the same error file.




      <listener ref="com.awginc.scm.tpa.offinvoice.util.InputRecordSkipListener" />




      <property name="resource" value="#{jobProperties['inputErrorResource']}" />



      <chunk item-count="3000">


      <include class="org.beanio.BeanReaderException" />



      <reader ref="beanIOItemReader">


      <property name="resource" value="#{jobProperties['inputResource']}" />

      <property name="streamName" value="#{jobProperties['inputStreamName']}" />

      <property name="streamMapping" value="#{jobProperties['inputStreamMapping']}" />




      <processor ref="com.awginc.scm.tpa.offinvoice.InputValidationProcessor" />


      <writer ref="beanIOItemWriter">


      <property name="resource" value="#{jobProperties['reformattedResource']}" />

      <property name="streamName" value="#{jobProperties['reformattedStreamName']}" />

      <property name="streamMapping" value="#{jobProperties['reformattedStreamMapping']}" />




        • 1. Re: ItemProcessor skip record
          Cheng Fang Master

          No, since item processor works after item reader.  However, such an exception from item processor will trigger SkipProcessListener.


          If your purpose is for better code organization, you can move the error-recording to a separate class that can be shared between reading, processing & writing parts.  That class can be a singleton, or bean class with appropriate CDI scope (e.g., StepScoped) to ensure the same bean instance is used by all parties.

          • 2. Re: ItemProcessor skip record
            Richard Moore Master

            Do you happen to have an example of this I could reference?

            • 3. Re: ItemProcessor skip record
              Cheng Fang Master

              import javax.inject.Named;

              import org.jberet.cdi.StepScoped;






              public class ErrorRecordingBean {

                 FileWriter fw = ...


                   public void addErrorRecord(String error) {...}


                  public void writeErrorRecord(String error) {...}




              In your read listener or item process listener, inject the above ErrorRecordingBean:



              private ErrorRecordingBean errorRecorder;


              With StepScoped, If your step is partitioned, then multiple partitions of the same step will share the same bean instance, and this bean class should be implemented in a thread-safe manner.  Even more so with Singleton scope, where all producers of error records will share the same instance.


              This is based on CDI, so make sure your batch artifact ref in job .xml is declared with cdi bean name (not the fully qualified class name).