final QueueInfo queueInfo = this.configuration.getQueueConfigurationManager().getQueueInfo(job.getTopic());
final AbstractJobQueue queue = (AbstractJobQueue)this.qManager.getQueue(queueInfo.queueName);
boolean stopped = false;
if ( queue != null ) {
stopped = queue.stopJob(job);
}
if ( forward && !stopped ) {
// mark the job as stopped
final JobHandler jh = new JobHandler(job,this.configuration);
jh.finished(JobState.STOPPED, true, -1);