D-Net

package eu.dnetlib.data.hadoop.action;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.beans.factory.annotation.Autowired;

import eu.dnetlib.data.hadoop.JobRegistry;

import eu.dnetlib.data.hadoop.rmi.HadoopServiceException;

import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;

import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;

public class KillJobAction extends AbstractHadoopAction {

	private static final Log log = LogFactory.getLog(KillJobAction.class); // NOPMD by marko on 11/24/08 5:02 PM

	@Autowired

	private JobRegistry jobRegistry;

	@Override

	public void executeAsync(final BlackboardServerHandler handler, final BlackboardJob bbJob) {

		final String jobid = bbJob.getParameters().get("job.id");

		log.info("killing job: " + jobid);

		try {

			jobRegistry.unregisterJob(jobid);

			handler.done(bbJob);

		} catch (HadoopServiceException e) {

			handler.failed(bbJob, e);

		}

	}

}