Class StagingItemProcessor<T>

    • Constructor Detail

      • StagingItemProcessor

        public StagingItemProcessor()
    • Method Detail

      • setJdbcTemplate

        public void setJdbcTemplate​(org.springframework.jdbc.core.JdbcOperations jdbcTemplate)
      • setDataSource

        public void setDataSource​(javax.sql.DataSource dataSource)
      • afterPropertiesSet

        public void afterPropertiesSet()
                                throws java.lang.Exception
        Specified by:
        afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
        Throws:
        java.lang.Exception
      • process

        public T process​(ProcessIndicatorItemWrapper<T> wrapper)
                  throws java.lang.Exception
        Use the technical identifier to mark the input row as processed and return unwrapped item.
        Specified by:
        process in interface ItemProcessor<ProcessIndicatorItemWrapper<T>,​T>
        Parameters:
        wrapper - to be processed
        Returns:
        potentially modified or new item for continued processing, null if processing of the provided item should not continue.
        Throws:
        java.lang.Exception - thrown if exception occurs during processing.