source: DCWoRMS/trunk/src/schedframe/scheduling/manager/tasks/AbstractJobRegistry.java @ 481

package schedframe.scheduling.manager.tasks;


import java.util.concurrent.ConcurrentHashMap;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import schedframe.scheduling.tasks.Job;
import schedframe.scheduling.tasks.JobInterface;
import schedframe.scheduling.tasks.Task;
import schedframe.scheduling.tasks.TaskInterface;


public abstract class AbstractJobRegistry /*extends ConcurrentHashMap<String, Job>*/ implements JobRegistry, Cloneable{
        
        private static final long serialVersionUID = 8409060063583755824L;

        
        protected static final ConcurrentHashMap<String, JobInterface<?>> jobs = new ConcurrentHashMap<String, JobInterface<?>>();
        
        protected AbstractJobRegistry(){
        }
        
        public boolean addJob(JobInterface<?> job) {
                jobs.put(job.getId(),  job);
                return true;
        }

        public boolean addTask(TaskInterface<?> task) {
                if(jobs.containsKey(task.getJobId())){
                        getJob(task.getJobId()).add((Task)task);
                        return true;
                } else {
                        return false;
                }
        }

        public JobInterface<?> getJobInfo(String jobId) {
                return jobs.get(jobId);
        }

        public TaskInterface<?> getTaskInfo(String jobId, String taskId) {
                Task task = null;
                Job job = getJob(jobId);
                
                if(job == null)
                        return null;
                
                try {
                        task = job.getTask(taskId);
                } catch (NoSuchFieldException e) {
                }
                return task;
        }
        
        public Job getJob(String jobId){
                return (Job)jobs.get(jobId);
        }

}