Listener

JobCompletionNotificationListener.java

package org.springBatch.listener;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springBatch.entity.Country;
import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.listener.JobExecutionListenerSupport;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

public class JobCompletionNotificationListener extends JobExecutionListenerSupport {
	
	private static final Logger log = LoggerFactory.getLogger(JobCompletionNotificationListener.class);

	private final JdbcTemplate jdbcTemplate;

	@Autowired
	public JobCompletionNotificationListener(JdbcTemplate jdbcTemplate) {
		this.jdbcTemplate = jdbcTemplate;
	}

	@Override
	public void afterJob(JobExecution jobExecution) {
		if(jobExecution.getStatus() == BatchStatus.COMPLETED) {
			log.info("--- JOB FINISHED! ---");
			log.info("Results:");

			List<Country> results = jdbcTemplate.query("SELECT id, name, currency FROM countries", new RowMapper<Country>() {
				@Override
				public Country mapRow(ResultSet rs, int row) throws SQLException {
					return new Country(rs.getInt(1), rs.getString(2), rs.getString(3));
				}
			});

			for (Country country : results) {
				log.info("--- " + country + " ---");
			}

		}
	}

}