View Javadoc

1   /*
2    * Copyright 2007-2008 the original author or authors.
3    * 
4    * Licensed under the Apache License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    * 
8    *      http://www.apache.org/licenses/LICENSE-2.0
9    * 
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   */
16  
17  package org.gwe.persistence.model.order;
18  
19  import java.io.Serializable;
20  import java.util.List;
21  import java.util.Map;
22  
23  import org.gwe.persistence.model.DaemonConfigDesc;
24  import org.gwe.persistence.model.JobInfo;
25  import org.gwe.persistence.model.live.JobLive;
26  
27  /**
28   * @author Marco Ruiz
29   * @since Aug 18, 2008
30   */
31  public abstract class JobDescriptor implements Serializable {
32  	
33  	protected transient JobLive jobLive;
34  	private transient Map<JobSideWorkerType, JobSideWorker> processors;
35  	
36  	public void initExecution(JobLive jobLive) throws Exception {
37  	    this.jobLive = jobLive;
38  	    this.processors = initExecutionInternal(jobLive);
39      }
40  	
41  	protected abstract Map<JobSideWorkerType, JobSideWorker> initExecutionInternal(JobLive jobLive) throws Exception;
42  
43  	public abstract Map<String, Object> getPermutationValues();
44  	
45      public StringBuffer toCSV(List<String> varNames) {
46      	StringBuffer result = new StringBuffer("");
47      	Map<String, Object> vars = getPermutationValues();
48      	
49      	for (String varName : varNames) {
50  			if (result.length() > 0) result.append(",");
51  	        Object varValue = vars.get(varName);
52  			result.append("\"").append(varValue == null ? "" : varValue).append("\"");
53          }
54  	    return result;
55      }
56  
57  	public void preProcess() throws Throwable {
58      	processors.get(JobSideWorkerType.PRE).execute(jobLive);
59      }
60  
61  	public void postProcess() throws Throwable {
62      	processors.get(JobSideWorkerType.POST).execute(jobLive);
63      }
64  
65  	public void finalizeExecution(JobLive jobLive) {}
66  
67  	public abstract void processSystemDependencies(DaemonConfigDesc config, JobInfo job);
68  }
69