[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/pool AbstractPoolJob
Brought to you by:
suresh_pragada
From: Suresh <sur...@us...> - 2006-09-14 23:05:02
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10276/controller/pool Modified Files: AbstractPoolJobLoader.java AbstractPoolJobProcessor.java Log Message: no message Index: AbstractPoolJobLoader.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/AbstractPoolJobLoader.java,v retrieving revision 1.10 retrieving revision 1.11 diff -C2 -d -r1.10 -r1.11 *** AbstractPoolJobLoader.java 13 Sep 2006 23:29:45 -0000 1.10 --- AbstractPoolJobLoader.java 14 Sep 2006 23:04:59 -0000 1.11 *************** *** 62,66 **** * and monitoring related methods. * ! * @param configProps Properties defined for this loader in job configuration. * @param pool Job Pool reference. * --- 62,66 ---- * and monitoring related methods. * ! * @param jobContext Context of the job being run. * @param pool Job Pool reference. * *************** *** 210,216 **** * <br> * <pre> ! * public class MyLoader * { ! * public ErrorCode loadPool(Map configProps) * { * for(int i=0;i<100;i++) --- 210,216 ---- * <br> * <pre> ! * public class MyLoader extends AbstractPoolJobLoader * { ! * public ErrorCode loadPool(JobContext jobContext) * { * for(int i=0;i<100;i++) *************** *** 231,235 **** * </p> * ! * @param configProps Configuration defined for this job loader in job configuration. * * @return Returns the final status of the loader. --- 231,235 ---- * </p> * ! * @param jobContext Context of the job being run. * * @return Returns the final status of the loader. Index: AbstractPoolJobProcessor.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/AbstractPoolJobProcessor.java,v retrieving revision 1.7 retrieving revision 1.8 diff -C2 -d -r1.7 -r1.8 *** AbstractPoolJobProcessor.java 13 Sep 2006 23:29:45 -0000 1.7 --- AbstractPoolJobProcessor.java 14 Sep 2006 23:04:59 -0000 1.8 *************** *** 57,61 **** * </p> * ! * @param configProps Properties defined for the processor in job configuration. * @param pool Job pool reference where job data needs to be pulled. * --- 57,61 ---- * </p> * ! * @param jobContext Context the job is being run. * @param pool Job pool reference where job data needs to be pulled. * *************** *** 209,226 **** /** ! * Chance to initialize itself using the information configured for this job ! * processor in job configuration. * ! * @param configProps Configuration defined for the job processor in job configuration. */ public abstract void initialize(JobContext jobContext); /** * */ public abstract ErrorCode process(Object jobData); /** ! * Chance to do any cleanup at the end of the processing. */ public abstract void cleanup(); --- 209,232 ---- /** ! * Chance to initialize itself using the information provided through ! * job context. This will be called only once for each processor and before ! * it start processing job data using process method. * ! * @param jobContext Context the job is being run. */ public abstract void initialize(JobContext jobContext); /** + * Execute the business logic on the given jobData and return the + * appropriate error code. The format and type of jobData is depend + * on the job loader. * + * @param jobData Data to be processed. */ public abstract ErrorCode process(Object jobData); /** ! * Chance to do any cleanup at the end of the processing. Called once per ! * each processor at the end of processing of all the jobs. */ public abstract void cleanup(); |