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();
|
