com.netflix.genie.web.services.impl

Class JobKillServiceImpl

java.lang.Object

com.netflix.genie.web.services.impl.JobKillServiceImpl

All Implemented Interfaces:

JobKillService

public class JobKillServiceImpl
extends java.lang.Object
implements JobKillService

Implementation of the JobKillService interface. Attempts to kill v3 jobs running on the local genie nodes. Attempts to kill v4 jobs running on remote agents.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
JobKillServiceImpl(JobKillServiceV3 jobKillServiceV3, JobKillServiceV4 jobKillServiceV4, JobPersistenceService jobPersistenceService) Constructor.

Method Summary

Modifier and Type	Method and Description
void	killJob(@NotBlank(message="No id entered. Unable to kill job.") java.lang.String id, @NotBlank(message="No reason provided.") java.lang.String reason) Kill the job with the given id if possible.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobKillServiceImpl

public JobKillServiceImpl(JobKillServiceV3 jobKillServiceV3,
                          JobKillServiceV4 jobKillServiceV4,
                          JobPersistenceService jobPersistenceService)

Constructor.

Parameters:

jobKillServiceV3 - Service to kill V3 jobs.

jobKillServiceV4 - Service to kill V4 jobs.

jobPersistenceService - Job persistence service

Method Detail

killJob

public void killJob(@NotBlank(message="No id entered. Unable to kill job.")
                    @NotBlank(message="No id entered. Unable to kill job.") java.lang.String id,
                    @NotBlank(message="No reason provided.")
                    @NotBlank(message="No reason provided.") java.lang.String reason)
             throws GenieException

Kill the job with the given id if possible. Should publish a JobFinishedEvent when done.

Specified by:

killJob in interface JobKillService

Parameters:

id - id of job to kill

reason - brief reason for requesting the job be killed

Throws:

GenieException - if there is an error