batchserver-cvs

[Suresh <sur...@us...>]

Update of /cvsroot/batchserver/batchserver/examples/poolcontroller/com/mycompany/jobs
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv28003

Added Files:
	IntegerJobLoader.java IntegerJobProcessor.java 
Log Message:
no message

--- NEW FILE: IntegerJobProcessor.java ---
package com.mycompany.jobs;

import org.jmonks.batch.framework.controller.pool.AbstractPoolJobProcessor;
import org.jmonks.batch.framework.JobContext;
import org.jmonks.batch.framework.ErrorCode;

public class IntegerJobProcessor extends AbstractPoolJobProcessor
{
    public IntegerJobProcessor()
    {
    }

    public void initialize(JobContext jobContext)
    {
    }

    public ErrorCode process(Object jobData)
    {
         Integer value=(Integer)jobData;
         // Perform business logic on jobData.
         System.out.println("Received Value = " + value.toString());

         return ErrorCode.JOB_COMPLETED_SUCCESSFULLY;
    }

    public void cleanup()
    {
    }
}


--- NEW FILE: IntegerJobLoader.java ---
package com.mycompany.jobs;

import org.jmonks.batch.framework.controller.pool.AbstractPoolJobLoader;
import org.jmonks.batch.framework.JobContext;
import org.jmonks.batch.framework.ErrorCode;

public class IntegerJobLoader extends AbstractPoolJobLoader
{
    public IntegerJobLoader()
    {
    }

    public ErrorCode loadPool(JobContext jobContext)
    {
         for(int i=0;i<10;i++)
             loadJobData(new Integer(i));
         loadJobData(null);

         return ErrorCode.JOB_COMPLETED_SUCCESSFULLY;
    }

    public long getTotalJobDataCount()
    {
         return 10;
    }
}