genie-web/src/main/java/com/netflix/genie/web/agent/apis/rpc/v4/endpoints/GRpcJobKillServiceImpl.java
@Override
    public void registerForKillNotification(
        final JobKillRegistrationRequest request,
        final StreamObserver<JobKillRegistrationResponse> responseObserver
    ) {
        final StreamObserver<JobKillRegistrationResponse> existingObserver =
            parkedJobKillResponseObservers.put(request.getJobId(), responseObserver);

        // If a previous observer/request is present,
        if (existingObserver != null) {
            existingObserver.onCompleted();
        }
    }
/**
     * Register to be notified when a kill request for the job is received.
     *
     * @param request          Request to register for getting notified when server gets a job kill request.
     * @param responseObserver The response observer
     */
Register to be notified when a kill request for the job is received.
@param request          Request to register for getting notified when server gets a job kill request.
@param responseObserver The response observer
Register to be notified when a kill request for the job is received . @param request Request to register for getting notified when server gets a job kill request . @param responseObserver The response observer
@Override
    public void registerForKillNotification(
        final JobKillRegistrationRequest request,
        final StreamObserver<JobKillRegistrationResponse> responseObserver
    ) {
        final StreamObserver<JobKillRegistrationResponse> existingObserver =
            parkedJobKillResponseObservers.put(request.getJobId(), responseObserver);
        if (existingObserver != null) {
            existingObserver.onCompleted();
        }
    }
@ Override public void registerForKillNotification ( final JobKillRegistrationRequest request , final StreamObserver < JobKillRegistrationResponse > responseObserver ) { final StreamObserver < JobKillRegistrationResponse > existingObserver = parkedJobKillResponseObservers . put ( request . getJobId ( ) , responseObserver ) ; if ( existingObserver != null ) { existingObserver . onCompleted ( ) ; } }
Register to be notified when a kill request for the job is received.
Register to be notified when a kill request for the job is received .
// If a previous observer/request is present,