agave-jobs/jobs-core/src/main/java/org/iplantc/service/jobs/managers/monitors/DefaultJobMonitor.java
/**
	 * Performs the remote call to make the job status check.
	 * @param queryCommand the command to run on the {@link ExecutionSystem}
	 * @return the response from the job check command.
	 * @throws RemoteJobMonitoringException if unable to query the remote job status
	 */
Performs the remote call to make the job status check.
@param queryCommand the command to run on the  ExecutionSystem
@return the response from the job check command.
@throws RemoteJobMonitoringException if unable to query the remote job status
Performs the remote call to make the job status check . @param queryCommand the command to run on the ExecutionSystem @return the response from the job check command . @throws RemoteJobMonitoringException if unable to query the remote job status
protected String queryRemoteJobStatus(String queryCommand) throws RemoteJobMonitoringException {
		try (RemoteSubmissionClient remoteSubmissionClient = getRemoteSubmissionClient()) {
			log.debug("Forking command \"" + queryCommand + "\" on " + remoteSubmissionClient.getHost() + ":" +
					remoteSubmissionClient.getPort() + " for job " + getJob().getUuid());
			String schedulerResponseText = remoteSubmissionClient.runCommand(queryCommand);
			log.debug("Response for job " + getJob().getUuid() + " monitoring command was: " + schedulerResponseText);
			return schedulerResponseText;
		} catch (Exception e) {
			throw new RemoteJobMonitoringException("Failed to retrieve status information for job " + getJob().getUuid() +
					" from remote system.", e);
		}
	}
protected String queryRemoteJobStatus ( String queryCommand ) throws RemoteJobMonitoringException { try ( RemoteSubmissionClient remoteSubmissionClient = getRemoteSubmissionClient ( ) ) { log . debug ( "Forking command \"" + queryCommand + "\" on " + remoteSubmissionClient . getHost ( ) + ":" + remoteSubmissionClient . getPort ( ) + " for job " + getJob ( ) . getUuid ( ) ) ; String schedulerResponseText = remoteSubmissionClient . runCommand ( queryCommand ) ; log . debug ( "Response for job " + getJob ( ) . getUuid ( ) + " monitoring command was: " + schedulerResponseText ) ; return schedulerResponseText ; } catch ( Exception e ) { throw new RemoteJobMonitoringException ( "Failed to retrieve status information for job " + getJob ( ) . getUuid ( ) + " from remote system." , e ) ; } }
Performs the remote call to make the job status check.
Performs the remote call to make the job status check .