batchserver-cvs — List to get the emails from cvs for check-ins.

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller JobController.java,NONE,1.1

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv30411/controller

Added Files:
	JobController.java 
Log Message:
Submitting the class skeltons

--- NEW FILE: JobController.java ---
package org.jmonks.batchserver.framework.controller;
import org.jmonks.batchserver.framework.config.*;
import org.jmonks.batchserver.framework.*;
import org.jmonks.batchserver.framework.mgmtmntr.JobMonitorMBean;
import org.jmonks.batchserver.framework.mgmtmntr;
import org.jmonks.batchserver.framework.mgmtmntr;
import org.jmonks.batchserver.framework.mgmtmntr.*;
import org.jmonks.batchserver.framework.common.*;

/**
 * <p>
 * Job Controller is the important component, which actually creates and starts the proper components to process the job. Controller can defines its own logic (architecture) to process the jobs. This creates and manages the complete architecture it defines to process the job.
 * This provides a factory method which returns the appropriate controller component based on the provided controller config object. This implements the management and monitoring interfaces to make sure all the controller implementations are manageable and monitorable.
 * </p>
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public abstract class JobController implements JobMonitorMBean, JobManagerMBean
{

    private Main mMain;
    private JobController()
    {
    }

    /**
     * <p>
     * This factory method loads the required implementation of the controller based on the controllerConfig received. First it tries to look for the existence of controller with this jobName in repository (If job is stopped in middle through MgmtMntrManager using restart=true flag, this controller will be stopped and persisted in the repository). By default, if job is stopped in the middle it will be restarted. To override this behaviour special property needs to be sent as "job-controller-restart=false" in the additional configuration. If it is false, it calls the releaseController method on repository to clear its current state and create a new controller using the configuration defined in controllerConfig.
     * 
     * @param	jobName		Name of the job to be started.
     * @param	controllerConfig	configuration object represents controller configuration.
     * 
     * @return	Returns the correct implementation of the controller.
     * </p>
     */
    public static org.jmonks.batchserver.framework.controller.JobController getJobController(String jobName, org.jmonks.batchserver.framework.config.ControllerConfig config)
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    {
        return null;















    }

    /**
     * Returns the controller configuration object.
     * 
     * @return	Returns the controller configuration object.
     */
    public ControllerConfig getControllerConfig()
    
    
    {
        return mControllerConfig;
    }

    /**
     * This method will be called by Main to process the job. This returns the exit status of the job, which will be communicate to everyone.
     * 
     * @return	Returns the exit status of the job.
     */
    public abstract org.jmonks.batchserver.framework.common.StatusCode process();

    /**
     * Returns the job name.
     * 
     * @return	Returns the job name.
     */
    public String getJobname()
    
    {
        return null;
    }

    public abstract int getExpectedRecordsCount();

    /**
     * @see org.jmonks.batchserver.framework.JobMonitorMBean#getProcessedRecords()
     */
    public abstract int getProcessedRecordsCount();

    /**
     * @see org.jmonks.batchserver.framework.JobMonitorMBean#getThreadCount()
     */
    public abstract String[] getThreadIDList();

    /**
     * @see org.jmonks.batchserver.framework.JobMonitorMBean#getThreadState(int)
     */
    public abstract org.jmonks.batchserver.framework.mgmtmntr.ThreadState getThreadState(String threadID);

    /**
     * @see org.jmonks.batchserver.framework.JobManagerMBean#getJobStatus()
     */
    public abstract org.jmonks.batchserver.framework.mgmtmntr.JobStatus getJobStatus();

    /**
     * @see org.jmonks.batchserver.framework.JobManagerMBean#stop(boolean)
     */
    public abstract boolean stop(boolean restart);

    /**
     * @see org.jmonks.batchserver.framework.JobManagerMBean#suspend
     */
    public abstract boolean suspend();

    /**
     * @see org.jmonks.batchserver.framework.JobManagerMBean#resume
     */
    public abstract boolean resume();

    /**
     * This method would enable the controller to deserialize its state from the repository.
     * 
     * @param	inputStream	Stream from which the controller needs to be recovered.
     */
    public abstract void readObject(java.io.ObjectInputStream inputStream);

    /**
     * This method enables the controller to persist/serializes on its own.
     * 
     * @param	outputStream	Persist/Serialize the state of the controller.
     */
    public abstract void writeObject(java.io.ObjectOutputStream outputStream);
}

[Batchserver-cvs] DefaultRepository.java,NONE,1.1 JobContext.java,NONE,1.1 JobStatistics.java,NONE,1.1 LoggingManager.java,NONE,1.1 Main.java,NONE,1.1 Repository.java,NONE,1.1

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

Update of /cvsroot/batchserver
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv30411

Added Files:
	DefaultRepository.java JobContext.java JobStatistics.java 
	LoggingManager.java Main.java Repository.java 
Log Message:
Submitting the class skeltons

--- NEW FILE: JobContext.java ---
package org.jmonks.batchserver.framework;

import org.jmonks.batchserver.framework.config.*;

/**
 * <p>
 * This class provides the interface to access various resources outside the framework.
 * This allows to access the framework configuration and get the reference
 * to repsoitory. 
 * </p>
 * @author : Suresh Pragada
 * @version 1.0
 */
public class JobContext
{
    private static JobContext context = new JobContext();

    private Repository mRepository;

    private JobContext()
    {
    }

    public static org.jmonks.batchserver.framework.JobContext getInstance()
    
    {
        return null;
    }

    /**
     * Gets the repository configured for this framework. It it cannot locate
     * the repository or cannot access the repository, it returns null.
     * 
     * @return	Returns the repository configured for this framework, null, if 
     * 	it cannot access the repository.
     */
    public org.jmonks.batchserver.framework.Repository getReposiotry()
    
    {
        return null;
    }

    /**
     * Gets the framework configuration. 
     * 
     * @return	Gets the framework configuration, null, if it cannot locate
     * 	the framework-config.xml file.
     */
    public FrameworkConfig getFrameworkConfig()
    
    {
        return null;
    }
}

--- NEW FILE: JobStatistics.java ---
package org.jmonks.batchserver.framework;

/**
 * This represents all the statistics related to the job. 
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public class JobStatistics
{

    private Date startTime;

    private Date endTime;

    private int recordsProcessed;

    private int maxMemoryUsage;

    private String jobName;
    public JobStatistics()
    {
    }

    /**
     * Sets the startime of the job.
     * 
     * @param	startTime	Starting time of the job.
     */
    public void setStartTime(Date startTime)
    {
    }

    /**
     * Sets the endtime of the job.
     * 
     * @param	endTime		Ending time of the job.
     */
    public void setEndTime(Date endTime)
    
    {
        this.endTime = endTime;
    }

    /**
     * Sets the number of the records processed in this job.
     * 
     * @param	recordCount	Sets the number of records got processed.
     */
    public void setRecordsProcessed(int recordCount)
    
    {
        this.recordsProcessed = recordCount;
    }

    /**
     * Sets the maximum memory used for the job.
     * 
     * @param	memoryUsaeg	Sets the memory usage by the job.
     */
    public void setMaxMemeoryUsage(int memoryUsage)
    {
    }

    /**
     * Gets the start time of this job.
     * 
     * @return	Returns the starting time of this job.
     */
    public Date getStartTime()
    
    {
        return startTime;
    }

    /**
     * Gets the ending time of this job.
     * 
     * @return Gets the end time of this job.
     */
    public Date getEndTime()
    
    {
        return endTime;
    }

    /**
     * Gets the number of records processed.
     * 
     * @return	Returns the number of records got processed.
     */
    public int getRecordsProcessed()
    
    {
        return recordsProcessed;
    }

    /**
     * Gets the maximum memory used by this job.
     * 
     * @return	Returns the max memory used by this job.
     */
    public int getMaxMemoryUsage()
    
    {
        return maxMemoryUsage;
    }

    /**
     * Gets the job name
     * 
     * @return Returns the name of this job.
     */
    public String getJobname()
    
    {
        return null;
    }

    /**
     * Sets the name of the job.
     * 
     * @param	jobName	Name of the job.
     */
    public void setJobname(String jobName)
    {
    }
}

--- NEW FILE: LoggingManager.java ---
package org.jmonks.batchserver.framework;
import org.jmonks.batchserver.framework.config.*;

/**
 * <p>
 * This class provides the logging services to the framework. 
 * It defines the default logging mechanism at the framework level
 * which works for all the jobs and provide the facility to 
 * use their own logging mechanism.
 * 
 * The default logging mechanism defined at the framework will
 * work like this. It reads the directory to create the log files from
 * the framework logging configuration <logging-directory> and creates a directory 
 * with the "job-name" and create the log files for each run. So, the format
 * will be
 * <br><br>
 * 	<directory-defined-in-config>/job-name/jobname_with_timestamp.log
 * <br><br>	
 * 
 * If job developer would like to override this logging mechanism, they can 
 * define their logging configuration in the element <job-config> in batch
 * configuration file.
 * </p>
 * @author : Suresh Pragada
 * @version 1.0
 */
public class LoggingManager {

    private static LoggingManager loggingManager = new LoggingManager();
    private LoggingManager()
    {
    }

    public static LoggingManager getInstance()
    
    {
        return null;
    }

    /**
     * <p>
     * This method accepts all the information available from framwork configuration
     * and job configuration and loads the required loggers appropriately. If jobLoggingConfig
     * is null, it uses frameworkLoggingConfig to initialize the logging.
     * 
     * @param	jobName	Name of the job.
     * @param	frameworkLoggingConfig	Logging configuration defined at the framework.
     * @param	jobLogginConfig	Logging configuration defined at the job.
     * </p>
     */
    public void loadLogging(String jobName, org.jmonks.batchserver.framework.config.FrameworkLoggingConfig frameworkLoggingConfig, org.jmonks.batchserver.framework.config.JobLoggingConfig jobLoggingConfig)
    {
    }

}

--- NEW FILE: Repository.java ---
package org.jmonks.batchserver.framework;

import org.jmonks.batchserver.framework.config.*;
import org.jmonks.batchserver.framework.controller.*;

/**
 * <p>
 * This interface provides utility methods to access and use the repository. 
 * There could be differnt implementations of the repository. Framework
 * configuration defines which implementation should be used for this framework.
 * This povides utility methods to logs the job statistics and persist any objects, 
 * transfer some information between the jobs and transfer some management and monitor 
 * information between framework and server.
 * </p>
 * @author : Suresh Pragada
 * @version 1.0
 */
public abstract class Repository
{

    private Repository()
    {
    }
    public static void getRepository(org.jmonks.batchserver.framework.config.RepositoryConfig config)
    {
    }

    /**
     * This method logs the job statistics given in the form JobStatistics object 
     * in the repository for further use. 
     * 
     * @param	statistics	Job Statistics object which holds all the statistics related to that job.
     * 
     * @return	Returns true if statistics can be logged, false, otherwise.
     */
    public abstract boolean logStatistics(org.jmonks.batchserver.framework.JobStatistics statistics);

    /**
     * Given data will be sent to the specified job behalf of this job.
     * 
     * @param	srcJN	Name of the source job.
     * @param	srcCmp	Name of the source componenet.
     * @param	tgtJN	Name of the target job.
     * @param	tgtCmp	Name of the target component.
     * @param	data	data that needs to be sent as the object.
     * 
     * @return	Returns true, if it could save the data to be sent to the next job.
     */
    public abstract boolean sendDatatoNextJob(String srcJN, String srcCmp, String tgtJN, String tgtCmp, Object data);

    /**
     * Gets the data that has been sent to this job.
     * 
     * @param	srcJN	Name of the source job.
     * @param	srcCmp	Name of the source componenet.
     * @param	tgtJN	Name of the target job.
     * @param	tgtCmp	Name of the target component.
     * 
     * @return	Returns the data, null, it it couldnt find any data.
     */
    public abstract Object getDataFromPreviousJob(String srcJN, String srcCmp, String tgtJN, String tgtCmp);

    /**
     * Registers the job management and monitoring info with the given job name.
     * 
     * @param	jobName	Name of the job.
     * @param	registrationInfo	Information to be associated with this job name.
     * 
     * @return	Return true, if it could assosciate this information, false, otherwise.
     */
    public abstract boolean registerJobMgmtMntrInfo(String jobName, Object registrationInfo);

    /**
     * Retrieves the management and monitoring information assosciated with this job.
     * 
     * @param	jobName	Name of the job.
     * 
     * @return	Returns the registered information, null, if it doesnt find any information.
     */
    public abstract Object lookupJobMgmtMntrInfo(String jobName);

    /**
     * Unregisters the job management and monitoring info assosciated with the given job name.
     * 
     * @param	jobName	Name of the job.
     * 
     * @return	Return true, it it could unregister the information, false, otherwise.
     */
    public abstract boolean unregisterJobMgmtMntrInfo(String jobName);

    /**
     * Gets the statistics related to that given job as a JobStatistics object array.
     * 
     * @param	jobName	Name of the job for which statistics are required.
     * @return	Returns the array of JobStatistics object, null, if it couldnt find any job with that name.
     */
    public abstract org.jmonks.batchserver.framework.JobStatistics[] getStatistics(String jobName);

    /**
     * Persist the controller in repository. This will be useful, when job wants to be restarted.
     * When controller receives stop signal from servier with restart flag, it persist itself into
     * the repository. 
     * 
     * @param	jobName		Name of the job
     * @param	controller	Controller object to be persisted.
     * 
     * @return	Returns true, if it could persist the controller, false, otherwise.
     */
    public abstract boolean saveController(org.jmonks.batchserver.framework.controller.JobController controller, String jobName);

    /**
     * Loads the controller assosicated with this job name in the repsoitory. When controller starts
     * execution, always, it looks into the reposiotry for restart. This can be overriden by passing addition
     * configuration property.
     * 
     * @param	jobName	Name of the job.
     * @return	Returns the controller object, null, if it couldnt find any.
     */
    public abstract org.jmonks.batchserver.framework.controller.JobController loadController(String jobName);

    /**
     * Releases the persistedcontroller object from repository.
     * 
     * @param	jobName	Name of the job.
     * @return	Returns true, if it could release the controller from repository, null, otherwise.
     */
    public abstract boolean releaseController(String jobName);
}

--- NEW FILE: Main.java ---
package org.jmonks.batchserver.framework;

import java.util.HashMap;
import java.util.Map;
import org.jmonks.batchserver.framework.config.*;
import org.jmonks.batchserver.framework.mgmtmntr.*;
import org.jmonks.batchserver.framework.controller.*;
import org.jmonks.batchserver.framework.common.*;



/**
 * <p>
 * This class is the interface to the batch framework. 
 * This provides the methods accept the information to identify the job and kick off. 
 * The framework can be executed either through command line as an independent program or from any other java program. 
 * The information on how to kickoff using these two methods available in {@link #main(String[])} and {@link #process(Map)} methods of this class.
 * <br><br>
 * </p>
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public class Main 
{

    private MgmtMntrManager mMgmtMntrManager;
    public Main()
    {
        
    }
    
    /**
     * <p>
     * This method provides the interface to execute the job from another java program. This accepts the job-name and additional configuration information relate to this job as a key value pairs in the map.  Among the entries in the map, there should be job-name key available.  
     * <br><br>
     * <pre>
     * 	import org.jmonks.batchserver.framework.Main;
     * 	import java.util.Map;
     * 	import java.util.HashMap();
     * 
     * 	Map configMap=new HashMap();
     * 	configMap.put("job-name","process_file_abc");
     * 	configMap.put("config-name1","config-value1");
     * 	configMap.put("config-name2","config-value2");
     * 	Main main=new Main();
     * 	int errorCode=main.process(configMap);
     * 	System.out.println("Job exited with return code : " + errorCode);
     * </pre>
     * <br><br>
     * Whatever the configuration key values passed here will override the values defined in job configuration.
     * </p>
     * <br>
     * @param	configMap	Map object consist of all the properties needed to kick off this batch job.
     * @return	Returns zero for success and non-zero for failure.
     */
    public org.jmonks.batchserver.framework.common.StatusCode process(Map configMap)
    
    
    
    {
        return null;


    }
    
    
    /**
     * <p>
     * This method provides the interface to execute the jobs from command line. This accepts the job name/job config and additional configuration information relate to this job as a command line parameters. Each parameter passed through line should be in the format name=value. Among these, either "jobname=xxxxxx" or "jobconfig=xxxxxxxxx" should exist. If these two passed in the parameters, job will exit with error. If job is invoking in independent mode through this method, the return value will be return as exit code. So, exit should be considered as return value.
     * </p>
     * <p>
     * The format to invoke the job using this interface is as follows. <br>
     * java org.jmonks.batchserver.framework.Main job-name=process_file_abc config-name1=config-value1 config-name2=config-value2
     * <br><br>
     * java org.jmonks.batchserver.framework.Main job-name=<job-config>...</job-config> config-name1=config-value1 config-name2=config-value2
     * <br><br>
     * Whatever the configuration paremters passed here will override the values defined in job configuration.
     * </p>
     * @param   args    Configuration details in command line params as name=value format
     * 
     */
    public static void main(String args[])
    {
        
        Map configMap=new HashMap();
        /**
         * parse command line parameters and populate the map.
         **/
        Main main=new Main();
        int errorCode=main.process(configMap);
        System.exit(errorCode);
    }


}

--- NEW FILE: DefaultRepository.java ---
package org.jmonks.batchserver.framework;


/**
 * <p>
 * This implementation of repository uses the DB4O database as the repository. It expects the following two properties present in the repository configuration in framework-cofig.xml file.
 * <br><br>
 * <pre>
 *    <repository-config repository-class-name="org.jmonks.batchserver.framework.DefaultRepository">
 *  <property key="repository-location">/batchserver/repository</property>
 *  <property key="repository-filename">batchserver_repository.db</property>
 *    </repository-config>
 * </pre>
 * <br><br>
 * Here repository-location defines where the DB4O database needs to be created and repository-filename defines the name of the file to be used as the repository.
 * 
 * </p>
 * @author : Suresh Pragada
 * @version 1.0
 */
public abstract class DefaultRepository extends Repository 
{
    DefaultRepository(java.util.Map configProps)
    {
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#logStatistics(org.jmonks.batchserver.framework.JobStatistics)
     */
    public boolean logStatistics(org.jmonks.batchserver.framework.JobStatistics statistics)
    
    {
        return true;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#sendDataToNextJob(String,String,String,String,Object)
     */
    public boolean sendDatatoNextJob(String srcJN, String srcCmp, String tgtJN, String tgtCmp, Object data)
    
    {
        return true;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#getDataFromPreviousJob(String,String,String,String)
     */
    public Object getDataFromPreviousJob(String srcJN, String srcCmp, String tgtJN, String tgtCmp)
    
    {
        return null;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#registerJobMgmtMntrInfo(String,Object)
     */
    public boolean registerJobMgmtMntrInfo(String jobName, Object registrationInfo)
    
    {
        return true;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#lookupJobMgmtMntrInfo(String)
     */
    public Object lookupJobMgmtMntrInfo(String jobName)
    
    {
        return null;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#unregisterJobMgmtMntrInfo(String)
     */
    public boolean unregisterJobMgmtMntrInfo(String jobName)
    
    {
        return true;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#getStatistics(String)
     */
    public org.jmonks.batchserver.framework.JobStatistics[] getStatistics(String jobName)
    
    {
        return null;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#saveController(org.jmonks.batchserver.framework.controller.JobController,String)
     */
    public boolean saveController(org.jmonks.batchserver.framework.controller.JobController controller, String jobName)
    
    {
        return true;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#loadController(String)
     */
    public org.jmonks.batchserver.framework.controller.JobController loadController(String jobName)
    
    {
        return null;
    }

    /**
     * @see org.jmonks.batchserver.framework.Repository#releaseController(String)
     */
    public boolean releaseController(String jobName)
    
    {
        return true;
    }

/**
 * <p>
 * This is the inner class in the DefaultRepository class to hold the data being transferred between the jobs. This will not have any functionality except holding the data. 
 * </p>
 * @author : Suresh Pragada
 * @version 1.0
 */
public class JobDataTransfer
{

    private String sourceJobName;

    private String sourceComponentName;

    private Object data;

    private int targetJobName;

    private int targetComponentName;
    public JobDataTransfer()
    {
    }


}




}

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config BasicJobControllerConfig.java,NONE,1.1 FrameworkConfig.java,NONE,1.1 JobConfig.java,NONE,1.1 JobConfigFactory.java,NONE,1.1 JobControllerConfig.java,NONE,1.1 PoolJobControllerConfig.java,NONE,1.1 Logging.properties,1.1,NONE

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv30411/config

Added Files:
	BasicJobControllerConfig.java FrameworkConfig.java 
	JobConfig.java JobConfigFactory.java JobControllerConfig.java 
	PoolJobControllerConfig.java 
Removed Files:
	Logging.properties 
Log Message:
Submitting the class skeltons

--- NEW FILE: JobConfig.java ---
/*
 * JobConfig.java
 *
 * Created on March 2, 2006, 11:40 AM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config;

import java.util.Map;

/**
 *
 * @author Suresh Pragada
 */
public abstract class JobConfig 
{
    protected String mJobName=null;
    
    protected Object mJobControllerConfig=null;
    
    public Object getJobControllerConfig()
    {
        return this.mJobControllerConfig;
    }
    
    public String getJobName()
    {
        return this.mJobName;
    }
}

--- NEW FILE: BasicJobControllerConfig.java ---
/*
 * BasicJobControllerConfig.java
 *
 * Created on March 2, 2006, 1:44 PM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config;

import java.util.Map;

/**
 *
 * @author Suresh Pragada
 */
public abstract class BasicJobControllerConfig extends JobControllerConfig
{
    protected final static String CONFIG_PROPERTY_PREFIX = "basic-job-controller-";
    
    protected String mBasicJobProcessorClassName=null;
    protected Map mBasicJobProcessorConfigProps=null;
    
    public String getBasicJobProcessorClassName()
    {
        return this.mBasicJobProcessorClassName;
    }
    
    public Map getBasicJobProcessorConfigProperties()
    {
        return this.mBasicJobProcessorConfigProps;
    }
    
    
    protected String getJobControllerConfigPropertyPrefix()
    {
        return BasicJobControllerConfig.CONFIG_PROPERTY_PREFIX;
    }
    
    /**
     * Base implementation overrides the properties in controller config props only.
     * So, override all the props like loader, process and pool here along with controller
     * config props.
     */
    public void overrideConfigProperties(Map newProps)
    {
        super.overrideConfigProperties(newProps);
        
        /**
         * Override the loader, processor and pool here.
         */
    }
    
}

--- NEW FILE: FrameworkConfig.java ---
/*
 * FrameworkConfig.java
 *
 * Created on March 2, 2006, 11:21 AM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config;

import java.util.Map;
import org.w3c.dom.Element;

/**
 *
 * @author Suresh Pragada
 */
public final class FrameworkConfig 
{
    private static final FrameworkConfig mFrameworkConfig=new FrameworkConfig();

    private static final String FRAMEWORK_CONFIG_FILE = "org.jmonks.batchserver.framework.config.framework-config.xml";
    
    /** Creates a new instance of FrameworkConfig */
    private FrameworkConfig() 
    {
    }
    
    public static FrameworkConfig getInstance()
    {
        return mFrameworkConfig;
    }
    
    public JobConfigFactoryConfig getJobConfigFactoryConfig()
    {
        return null;
    }
    
    public LoggingConfig getLoggingConfig()
    {
        return null;
    }
    
    
    public MgmtMntrConfig getMgmtMntrConfig()
    {
        return null;
    }

    public FrameworkConfig$RepositoryConfig getRepositoryConfig()
    {
        return null;
    }
    
    public class JobConfigFactoryConfig
    {
        private JobConfigFactoryConfig(Element jobConfigFactoryElement)
        {
            
        }
        
        public String getJobConfigFactoryClassName()
        {
            return null;
        }
        
        public Map getJobConfigFactoryProperties()
        {
            return null;
        }
    }
    
    public class LoggingConfig
    {
        private LoggingConfig(Element loggingConfigElement)
        {
            
        }
        
        public String getLoggingDirecotry()
        {
            return null;
        }
        
        public int getFrameworkLogLevel()
        {
            return 1;
        }
        
        public String getBasePackageName()
        {
            return null;
        }
    }
    
    public class MgmtMntrConfig
    {
        private MgmtMntrConfig(Element mgmtMntrConfigElement)
        {
            
        }
        
        public String getMgmtMntrClassName()
        {
            return null;
        }
        
        public Map getMgmtMntrProperties()
        {
            return null;
        }
    }
    
    public class RepositoryConfig
    {
        private RepositoryConfig(Element repositoryConfigElement)
        {
        }
        
        public String getRepositoryClassName()
        {
            return null;
        }
        
        public Map getRepositoryConfigProperties()
        {
            return null;
        }
    }
}

--- NEW FILE: JobConfigFactory.java ---
/*
 * JobConfigFactory.java
 *
 * Created on March 2, 2006, 11:35 AM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config;

/**
 *
 * @author Suresh Pragada
 */
public abstract class JobConfigFactory 
{
    /** Creates a new instance of JobConfigFactory */
    public static JobConfigFactory getJobConfigFactory(FrameworkConfig.JobConfigFactoryConfig factoryConfig) 
    {
        return null;
    }
    
    public abstract JobConfig getJobConfig(String jobName);
    
}

--- NEW FILE: JobControllerConfig.java ---
/*
 * JobControllerConfig.java
 *
 * Created on March 2, 2006, 12:12 PM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config;
import java.util.Map;

/**
 *
 * @author Suresh Pragada
 */
public abstract class JobControllerConfig 
{
    protected String mJobControllerClassName=null;
    
    protected Map mJobControllerConfigProps=null;
    
    public String getJobControllerClasName()
    {
        return this.mJobControllerClassName;
    }
    
    
    public Map getJobControllerConfigProperties()
    {
        return this.mJobControllerConfigProps;
    }
    
    /**
     * Overrides all the config properties by taking the prefix from sub classes.
     */
    public void overrideConfigProperties(Map newProps)
    {
    
    }
    
    protected abstract String getJobControllerConfigPropertyPrefix();
}

--- Logging.properties DELETED ---

--- NEW FILE: PoolJobControllerConfig.java ---
/*
 * PoolJobControllerConfig.java
 *
 * Created on March 2, 2006, 1:24 PM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config;

import java.util.Map;

/**
 *
 * @author Suresh Pragada
 */
public abstract class PoolJobControllerConfig extends JobControllerConfig
{
    protected final static String CONFIG_PROPERTY_PREFIX = "pool-job-controller-";
    
    protected String mPoolJobLoaderClassName=null;
    protected Map mPoolJobLoaderConfigProps=null;
    protected String mPoolJobProcessorClassName=null;
    protected Map mPoolJobProcessorConfigProps=null;
    protected String mPoolClassName=null;
    protected Map mPoolConfigProps=null;
    
    public String getPoolJobLoaderClassName()
    {
        return this.mPoolJobLoaderClassName;
    }
    
    public Map getPoolJobLoaderConfigProperties()
    {
        return this.mPoolJobLoaderConfigProps;
    }
    
    public String getPoolJobProcessorClassName()
    {
        return this.mPoolJobProcessorClassName;
    }
    
    public Map getPoolJobProcessorConfigProperties()
    {
        return this.mPoolJobProcessorConfigProps;
    }
    
    public String getPoolClassName()
    {
        return this.mPoolClassName;
    }
    
    public Map getPoolConfigProperties()
    {
        return this.mPoolConfigProps;
    }
    
    protected String getJobControllerConfigPropertyPrefix()
    {
        return PoolJobControllerConfig.CONFIG_PROPERTY_PREFIX;
    }
    
    /**
     * Base implementation overrides the properties in controller config props only.
     * So, override all the props like loader, process and pool here along with controller
     * config props.
     */
    public void overrideConfigProperties(Map newProps)
    {
        super.overrideConfigProperties(newProps);
        
        /**
         * Override the loader, processor and pool here.
         */
    }
}

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config/db DBBasicJobControllerConfig.java,NONE,1.1 DBJobConfig.java,NONE,1.1 DBJobConfigFactory.java,NONE,1.1 DBJobControllerConfig.java,NONE,1.1 DBPoolJobControllerConfig.java,NONE,1.1

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv30411/config/db

Added Files:
	DBBasicJobControllerConfig.java DBJobConfig.java 
	DBJobConfigFactory.java DBJobControllerConfig.java 
	DBPoolJobControllerConfig.java 
Log Message:
Submitting the class skeltons

--- NEW FILE: DBJobConfig.java ---
/*
 * DBJobConfig.java
 *
 * Created on March 2, 2006, 11:58 AM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config.db;

import org.jmonks.batchserver.framework.config.JobConfig;

/**
 *
 * @author Suresh Pragada
 */
public class DBJobConfig extends JobConfig
{
    
    /** Creates a new instance of DBJobConfig */
    DBJobConfig(Object dbValueToLoadJobConfig) 
    {
        
    }
    
}

--- NEW FILE: DBJobConfigFactory.java ---
/*
 * DBJobConfigFactory.java
 *
 * Created on March 2, 2006, 12:07 PM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config.db;

import java.util.Map;
import org.jmonks.batchserver.framework.config.JobConfig;
import org.jmonks.batchserver.framework.config.JobConfigFactory;

/**
 *
 * @author Suresh Pragada
 */
public class DBJobConfigFactory extends JobConfigFactory
{
    private Map mConfigFactoryProps=null;
    /** Creates a new instance of DBJobConfigFactory */
    public DBJobConfigFactory(Map configFactoryProps) 
    {
        
    }
    
    public JobConfig getJobConfig(String jobName)
    {
        /**
         * Look up job configuration in database and pass that to DBJobConfig.
         */
        return new DBJobConfig(null);
    }
}

--- NEW FILE: DBBasicJobControllerConfig.java ---
/*
 * DBBasicJobControllerConfig.java
 *
 * Created on March 2, 2006, 1:55 PM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config.db;

import org.jmonks.batchserver.framework.config.BasicJobControllerConfig;

/**
 *
 * @author Suresh Pragada
 */
public class DBBasicJobControllerConfig extends BasicJobControllerConfig
{
   /** Creates a new instance of DBBasicJobControllerConfig */
    DBBasicJobControllerConfig(Object dbValueToReadControllerConfig) 
    {
    }
    
}

--- NEW FILE: DBPoolJobControllerConfig.java ---
/*
 * DBPoolJobControllerConfig.java
 *
 * Created on March 2, 2006, 1:41 PM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config.db;

import org.jmonks.batchserver.framework.config.PoolJobControllerConfig;

/**
 *
 * @author Suresh Pragada
 */
public class DBPoolJobControllerConfig extends PoolJobControllerConfig
{
    /** Creates a new instance of DBPoolJobControllerConfig */
    DBPoolJobControllerConfig(Object dbValueToReadControllerConfig) 
    {
        /**
         * Load all the properties defined in base classes using the object passed
         * as input.
         */
    }
    
}

--- NEW FILE: DBJobControllerConfig.java ---
/*
 * DBJobControllerConfig.java
 *
 * Created on March 2, 2006, 1:22 PM
 *
 * To change this template, choose Tools | Options and locate the template under
 * the Source Creation and Management node. Right-click the template and choose
 * Open. You can then make changes to the template in the Source Editor.
 */

package org.jmonks.batchserver.framework.config.db;

import org.jmonks.batchserver.framework.config.JobControllerConfig;

/**
 *
 * @author Suresh Pragada
 */
public abstract class DBJobControllerConfig extends JobControllerConfig
{
    public static JobControllerConfig getJobControllerConfig(Object dbValueToReadControllerConfig)
    {
        return null;
    }
}

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/pool AbstractPoolJobLoader.java,NONE,1.1 AbstractPoolJobProcessor.java,NONE,1.1 CollectionJobPool.java,NONE,1.1 DefaultCollectionJobPool.java,NONE,1.1 JobPool.java,NONE,1.1 OrderedCollectionJobPool.java,NONE,1.1 PoolJobController.java,NONE,1.1 PoolJobLoader.java,NONE,1.1 PoolJobProcessor.java,NONE,1.1

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv30411/controller/pool

Added Files:
	AbstractPoolJobLoader.java AbstractPoolJobProcessor.java 
	CollectionJobPool.java DefaultCollectionJobPool.java 
	JobPool.java OrderedCollectionJobPool.java 
	PoolJobController.java PoolJobLoader.java 
	PoolJobProcessor.java 
Log Message:
Submitting the class skeltons

--- NEW FILE: PoolJobLoader.java ---
package org.jmonks.batchserver.framework.controller.pool;
import org.jmonks.batchserver.framework.config.*;

/**
 * Loader is the one which loads the job data into the pool. This inteface defines the responsibilites of the loader and some of these responsibilities will be implemented by AbstractPoolJobLoader.
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public interface PoolJobLoader
{
    public void initialize(org.jmonks.batchserver.framework.controller.pool.JobPool pool, org.jmonks.batchserver.framework.config.PoolJobLoaderConfig config);

    public void cleanup();

    public int loadPool();

    public boolean suspend();

    public boolean resume();

    public boolean stop();

    public int getTotalRecords();

    public Object getLoaderState();

    public void initialize(Map configProps, org.jmonks.batchserver.framework.controller.pool.JobPool pool);
}

--- NEW FILE: JobPool.java ---
package org.jmonks.batchserver.framework.controller.pool;

import org.jmonks.batchserver.framework.config.*;

/**
 * <p>
 * Pool provides the interface to load the job information into it and retrieves the job information from the pool.
 * </p>
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public interface JobPool
{
    public boolean loadJobData(Object jobData);

    public Object getNextJobData();

    public void initialize(org.jmonks.batchserver.framework.config.JobPoolConfig config);

    public void cleanup();

    public int getLoadedCount();

    public void getProcessedCount();
}

--- NEW FILE: AbstractPoolJobProcessor.java ---
package org.jmonks.batchserver.framework.controller.pool;

import org.jmonks.batchserver.framework.*;
import org.jmonks.batchserver.framework.config.*;
import org.jmonks.batchserver.framework.controller.pool;
import org.jmonks.batchserver.framework.controller.pool;



/**
 * <p>
 * Abstract job processor implements some of responsiblites defined by the job processor and leaves the application specific functionality implementation to the final processor.
 * </p>
 * @author : Suresh Pragada
 * @version 1.0
 */
public abstract class AbstractPoolJobProcessor implements PoolJobProcessor
{

    private JobPool mJobPool;
    public AbstractPoolJobProcessor()
    {
    }

    public abstract void initialize(org.jmonks.batchserver.framework.config.PoolJobProcessorConfig config);

    public boolean suspend()
    {
        return true;
    }

    public boolean resume()
    {
        return true;
    }

    public boolean stop()
    {
        return true;
    }

    public void initialize(org.jmonks.batchserver.framework.controller.pool.JobPool pool, org.jmonks.batchserver.framework.config.PoolJobProcessorConfig config)
    {
    }

    public abstract void cleanup();

    public int processPool()
    {
        return 0;
    }

    public Object getProcessorState()
    {
        return null;
    }

    public void initialize(Map configProps, org.jmonks.batchserver.framework.controller.pool.JobPool pool)
    {
    }
}

--- NEW FILE: PoolJobProcessor.java ---
package org.jmonks.batchserver.framework.controller.pool;

/**
 * Processor is the one which processes the job data. This interface defines the responsiblities of the job processor.
 * 
 * @author : Suresh pragada
 * @version 1.0
 */
public interface PoolJobProcessor
{
    public boolean suspend();

    public boolean resume();

    public boolean stop();

    public void initialize(org.jmonks.batchserver.framework.controller.pool.JobPool pool, org.jmonks.batchserver.framework.config.PoolJobProcessorConfig config);

    public void cleanup();

    public int processPool();

    public Object getProcessorState();

    public void initialize(Map configProps, org.jmonks.batchserver.framework.controller.pool.JobPool pool);
}

--- NEW FILE: DefaultCollectionJobPool.java ---
package org.jmonks.batchserver.framework.controller.pool;

/**
 * <p>
 * This is the default pool implementation for the PoolJobController. This provides the basic pool functionality using java utility collection. This uses the ArrayList for its implementation.
 * </p>
 * @author : Suresh Pragada
 * @version 1.0
 */
public class DefaultCollectionJobPool extends CollectionJobPool
{
    public DefaultCollectionJobPool()
    {
    }

    public List getCollection()
    {
        return null;
    }
}

--- NEW FILE: AbstractPoolJobLoader.java ---
package org.jmonks.batchserver.framework.controller.pool;

import org.jmonks.batchserver.framework.config.*;
import org.jmonks.batchserver.framework.controller.pool;



/**
 * AbstractPoolJobLoader does the basic implementation of the job loader responsibilities by leaving the job specific functionality implementation to the final loader.
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public abstract class AbstractPoolJobLoader implements PoolJobLoader
{

    private JobPool mJobPool;
    public AbstractPoolJobLoader()
    {
    }

    public abstract int loadJobData();

    public abstract void initialize(org.jmonks.batchserver.framework.config.PoolJobLoaderConfig config);

    public abstract Object getNextLoadableJobData();

    public void initialize(org.jmonks.batchserver.framework.controller.pool.JobPool pool, org.jmonks.batchserver.framework.config.PoolJobLoaderConfig config)
    {
    }

    public abstract void cleanup();

    public int loadPool()
    {
        return 0;
    }

    public boolean suspend()
    {
        return true;
    }

    public boolean resume()
    {
        return true;
    }

    public boolean stop()
    {
        return true;
    }

    public abstract int getTotalRecords();

    public Object getLoaderState()
    {
        return null;
    }

    public void initialize(Map configProps, org.jmonks.batchserver.framework.controller.pool.JobPool pool)
    {
    }
}

--- NEW FILE: OrderedCollectionJobPool.java ---
package org.jmonks.batchserver.framework.controller.pool;


/**
 * <p>
 * This provides the information to and from the pool based on the order. This uses the LinkedList as its collection.
 * </p>
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public class OrderedCollectionJobPool extends CollectionJobPool
{
    public OrderedCollectionJobPool()
    {
    }

    public List getCollection()
    {
        return null;
    }
}

--- NEW FILE: PoolJobController.java ---
package org.jmonks.batchserver.framework.controller.pool;
import org.jmonks.batchserver.framework.*;
import org.jmonks.batchserver.framework.controller.JobController;
import org.jmonks.batchserver.framework.controller.*;
import org.jmonks.batchserver.framework.mgmtmntr.*;
import org.jmonks.batchserver.framework.common.*;



/**
 * <p>
 * PoolJobController provides the job architecture based on the pool concept, where a loader is load all the information to be processed into the pool and processors(>=1) retrieves this information from pool and process them. As this subclasses the abstract JobController, it implements all the management and monitoring methods. It provides the abstract loader and processor classes to be overriden by job implementation and comes with different implementation of pools.
 * <br><br>
 * To write any job using this controller, developer needs to write a loader class extends AbstractPoolJobLoader, which loads the data needs to be processed into the pool and write a processor class extending the AbstractPoolJobProcessor, which process the data from the pool.
 * Once implementation is done, this job should be configured either using the XML configuration or DB configuration.
 * 
 * <br><br>
 * XML Configuration is as follows <br><br>
 * <pre>
 *    <job-config job-name="process_file_abc">
 *        <job-controller controller-class-name="org.jmonks.batchserver.framework.controller.pool.PoolJobController" 
 *            controller-config-class-name="org.jmonks.batchserver.framework.config.PoolControllerConfig">
 *            <job-loader pool-job-loader-class-name="com.mycompany.batch.processfileabc.AbcJobLoader">
 *                <property key="loader-info1">loader-value1</property>
 *            </job-loader>
 *            <job-processor pool-job-processor-class-name="com.mycompany.batch.processfileabc.AbcJobLoader">
 *                <thread-count>1</thread-count>
 *                <property key="processor-info1">processor-value1</property>
 *            </job-processor>
 *            <job-pool job-pool-class-name="org.jmonks.batchserver.framework.controller.pool.DefaultJobPool">
 *                <property key="pool-size">50000</property>
 *            </job-pool>
 *            <property key="controller-info1">controller-value1</property>
 *        </job-controller>
 *        <job-logging-config>
 *            <logging-property-file>com.mycompany.batch.processfileabc.Logging</logging-property-file>
 *        </job-logging-config>
 *    </job-config>
 * </pre>
 * </p>
 * @author : Suresh Pragada
 * @version 1.0
 */
public class PoolJobController extends JobController   
{

    private PoolJobProcessor mJobProcessor;

    private JobPool mJobPool;

    private PoolJobLoader mPoolJobLoader;
    public PoolJobController(JobControllerConfig config)
    {
    }

    public org.jmonks.batchserver.framework.common.StatusCode process()
    
    {
        return null;
    }

    /**
     * Returns the total number of records this job gonna process. This information will be obtained from the pool loader.
     * 
     * @return	Returns the number of records this job gonna process.
     */
    public int getExpectedRecordsCount()
    
    
    
    {
        return 0;


    }

    /**
     * Number of records this job processed so far. This information will be obtained from the pool.
     * 
     * @return	Returns the number of records processed so far.
     */
    public int getProcessedRecordsCount()
    
    
    {
        return 0;

    }

    /**
     * Returns the number of threads creates to process this job. This includes each thread for loader and pool and the specified number of threads for the processor.
     * 
     * @return	Returns the number of threads controller created to process this job.
     */
    public String getThreadIDList()
    
    
    {
        return null;

    }

    /**
     * Returns the current state of the thread.
     * 
     * @param	threadNo	Thread number.
     * @return	Retuns the current state of the thread.
     */
    public org.jmonks.batchserver.framework.mgmtmntr.ThreadState getThreadState(String threadID)
    
    
    {
        return null;

    }

    /**
     * Returns the status of the job.
     * 
     * @return Returns the status of the job.
     */
    public org.jmonks.batchserver.framework.mgmtmntr.JobStatus getJobStatus()
    
    
    {
        return null;

    }

    /**
     * This calls the stop method on the loader processor and persists the loader, pool and processor, if restart flag is true and return with appropriate return code.
     */
    public boolean stop(boolean restart)
    
    {
        return true;
    }

    /**
     * This calls the suspend on the loader and processor threads.
     * 
     * @return	Returns true, if it could suspend the processes, false, otherwise.
     */
    public boolean suspend()
    
    {
        return true;
    }

    /**
     * This would resume the job.
     * 
     * @return	Returns true, if it could resume the job, false otherwise.
     */
    public boolean resume()
    
    {
        return true;
    }

    /**
     * @see org.jmonks.batchserver.framework.controller.JobController#readObject(ObjectInputStream)
     */
    public void readObject(java.io.ObjectInputStream inputStream)
    {
    }

    /**
     * @see org.jmonks.batchserver.framework.controller.JobController#writeObject(ObjectOutputStream)
     */
    public void writeObject(java.io.ObjectOutputStream outputStream)
    {
    }


}

--- NEW FILE: CollectionJobPool.java ---
package org.jmonks.batchserver.framework.controller.pool;

/**
 * <p>
 * This provides the pool implementaiton using java utility collections. This is the default implementatio of pool, unless developer configured an another one.
 * </p>
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public abstract class CollectionJobPool implements JobPool
{
    public CollectionJobPool()
    {
    }

    public abstract List getCollection();

    public boolean loadJobData(Object jobData)
    {
        return true;
    }

    public Object getNextJobData()
    {
        return null;
    }

    public void initialize(org.jmonks.batchserver.framework.config.JobPoolConfig config)
    {
    }

    public void cleanup()
    {
    }

    public int getLoadedCount()
    
    {
        return 0;
    }

    public void getProcessedCount()
    {
    }
}

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/basic BasicJobController.java,NONE,1.1 BasicJobProcessor.java,NONE,1.1

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv30411/controller/basic

Added Files:
	BasicJobController.java BasicJobProcessor.java 
Log Message:
Submitting the class skeltons

--- NEW FILE: BasicJobProcessor.java ---
package org.jmonks.batchserver.framework.controller.basic;
import org.jmonks.batchserver.framework.config.BasicJobProcessorConfig;
import org.jmonks.batchserver.framework.common.*;

/**
 * <p>
 * This is the basic job processor. This interface lets the developers to extend this interface and implement their logic.
 * </p>
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public interface BasicJobProcessor
{
    public boolean suspend();

    public boolean resume();

    public boolean stop();

    public void initialize(BasicJobProcessorConfig Unnamed);

    public org.jmonks.batchserver.framework.common.StatusCode process();

    public void cleanup();

    public Object getProcessorState();

    public int getTotalCount();

    public int getProcessedCount();
}

--- NEW FILE: BasicJobController.java ---
package org.jmonks.batchserver.framework.controller.basic;
import org.jmonks.batchserver.framework.controller.*;
import org.jmonks.batchserver.framework.mgmtmntr.*;
import org.jmonks.batchserver.framework.common.*;

/**
 * <p>
 * This is the basic implementation of Job Controller. 
 * </p>
 * 
 * @author : Suresh Pragada
 * @version 1.0
 */
public class BasicJobController extends JobController {

    private BasicJobProcessor mBasicJobProcessor;
    public BasicJobController()
    {
    }

    public org.jmonks.batchserver.framework.common.StatusCode process()
    
    {
        return null;
    }

    /**
     * Returns the total number of records.
     * 
     * @return	Returns the total number of records the job gonna process.
     */
    public int getExpectedRecordsCount()
    
    
    
    {
        return 0;


    }

    /**
     * Returns the numebr of records processed so far.
     */
    public int getProcessedRecordsCount()
    
    
    {
        return 0;

    }

    /**
     * Returns the thread count.
     */
    public String getThreadIDList()
    
    
    {
        return null;

    }

    /**
     * Returns the state of the thread as a ThreadState object.
     */
    public org.jmonks.batchserver.framework.mgmtmntr.ThreadState getThreadState(String threadID)
    
    
    {
        return null;

    }

    /**
     * Returns the job status.
     */
    public org.jmonks.batchserver.framework.mgmtmntr.JobStatus getJobStatus()
    
    
    {
        return null;

    }

    /**
     * Stops the job and persist the state of this job, if restart flag is true.
     */
    public boolean stop(boolean restart)
    
    {
        return true;
    }

    /**
     * Suspends the job.
     */
    public boolean suspend()
    
    {
        return true;
    }

    /**
     * Resume the job
     */
    public boolean resume()
    
    {
        return true;
    }

    /**
     * @see org.jmonks.batchserver.framework.controller.JobController#readObject(ObjectInputStream)
     */
    public void readObject(java.io.ObjectInputStream inputStream)
    {
    }

    /**
     * @see org.jmonks.batchserver.framework.controller.JobController#writeObject(ObjectOutputStream)
     */
    public void writeObject(java.io.ObjectOutputStream outputStream)
    {
    }
}

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/basic - New directory

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv29147/basic

Log Message:
Directory /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic added to the repository

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/mgmtmntr - New directory

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/mgmtmntr
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv28486/mgmtmntr

Log Message:
Directory /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/mgmtmntr added to the repository

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config/xml - New directory

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/xml
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv27593/xml

Log Message:
Directory /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/xml added to the repository

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config/db - New directory

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv27240/db

Log Message:
Directory /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db added to the repository

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config batch-config.xml,1.2,1.3 framework-config.xml,1.1,1.2

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv26600

Modified Files:
	batch-config.xml framework-config.xml 
Log Message:
no message

Index: framework-config.xml
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/framework-config.xml,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** framework-config.xml	28 Feb 2006 04:18:10 -0000	1.1
--- framework-config.xml	3 Mar 2006 04:14:11 -0000	1.2
***************
*** 1,4 ****
  <framework-config>
!     <job-config-reader-config config-reader-class-name="org.jmonks.batchserver.framework.config.XMLJobConfigReader">
          <property key="config-file-absolute-location">/batchserver/config/batch-config.xml</property>
          <!-- 
--- 1,4 ----
  <framework-config>
!     <job-config-factory-config config-reader-class-name="org.jmonks.batchserver.framework.config.xml.XMLJobConfigFactory">
          <property key="config-file-absolute-location">/batchserver/config/batch-config.xml</property>
          <!-- 
***************
*** 6,18 ****
          <property key="config-file-classpath-location">org.jmonks.batchserver.framework.config.batch-config.xml</property> 
          -->
!     </job-config-reader-config>
      <repository-config repository-class-name="org.jmonks.batchserver.framework.DefaultRepository">
          <property key="repository-location">/batchserver/repository</property>
          <property key="repository-filename">batchserver_repository.db</property>
      </repository-config>
!     <framework-logging-config>
!         <log-file-location>/batchserver/logs</log-file-location>
!         <job-package-base-name>com.mycompany.batch</job-package-base-name>
!     </framework-logging-config>
      <mgmt-mntr-config mgmt-mntr-class-name="org.jmonks.batchserver.framework.mgmtmntr.DefaultMgmtMntrManager">
          <property key="port-range">15000-20000</property>
--- 6,19 ----
          <property key="config-file-classpath-location">org.jmonks.batchserver.framework.config.batch-config.xml</property> 
          -->
!     </job-config-factory-config>
      <repository-config repository-class-name="org.jmonks.batchserver.framework.DefaultRepository">
          <property key="repository-location">/batchserver/repository</property>
          <property key="repository-filename">batchserver_repository.db</property>
      </repository-config>
!     <logging-config>
!         <logging-directory>/batchserver/logs</logging-directory>
!         <logging-level>DEBUG</logging-level>
!         <job-base-package-name>com.mycompany.batch</job-base-package-name>
!     </logging-config>
      <mgmt-mntr-config mgmt-mntr-class-name="org.jmonks.batchserver.framework.mgmtmntr.DefaultMgmtMntrManager">
          <property key="port-range">15000-20000</property>

Index: batch-config.xml
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/batch-config.xml,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** batch-config.xml	28 Feb 2006 04:22:25 -0000	1.2
--- batch-config.xml	3 Mar 2006 04:14:11 -0000	1.3
***************
*** 2,7 ****
  <batch-config>
      <job-config job-name="process_file_abc">
!         <job-controller controller-class-name="org.jmonks.batchserver.framework.controller.pool.PoolJobController" 
!             controller-config-class-name="org.jmonks.batchserver.framework.config.PoolControllerConfig">
              <pool-job-loader pool-job-loader-class-name="com.mycompany.batch.processfileabc.AbcJobLoader">
                  <property key="pool-job-loader-key1">loader-value1</property>
--- 2,7 ----
  <batch-config>
      <job-config job-name="process_file_abc">
!         <job-controller job-controller-class-name="org.jmonks.batchserver.framework.controller.pool.PoolJobController" 
!             job-controller-config-class-name="org.jmonks.batchserver.framework.config.PoolControllerConfig">
              <pool-job-loader pool-job-loader-class-name="com.mycompany.batch.processfileabc.AbcJobLoader">
                  <property key="pool-job-loader-key1">loader-value1</property>
***************
*** 9,30 ****
              <pool-job-processor pool-job-processor-class-name="com.mycompany.batch.processfileabc.AbcJobLoader">
                  <thread-count>1</thread-count>
!                 <property key="pool-job-processor-info1">processor-value1</property>
              </pool-job-processor>
              <job-pool job-pool-class-name="org.jmonks.batchserver.framework.controller.pool.DefaultJobPool">
                  <property key="job-pool-size">50000</property>
              </job-pool>
!             <property key="job-controller-restart">true</property>
          </job-controller>
-         <job-logging-config>
-             <logging-property-file>com.mycompany.batch.processfileabc.Logging</logging-property-file>
-         </job-logging-config>
      </job-config>
      <job-config>
!         <job-controller controller-class-name="org.jmonks.batchserver.framework.controller.basic.BasicJobController" 
!             controller-config-class-name="org.jmonks.batchserver.framework.config.BasicJobControllerConfig">
              <basic-job-processor basic-job-processor-class-name="com.mycompany.batch.processfilexyz.XyzProcessor">
                  <property key="basic-job-processor-key1">processor-value1</property>
              </basic-job-processor>
!             <property key="job-controller-restart">true</property>
          </job-controller>
      </job-config>
--- 9,27 ----
              <pool-job-processor pool-job-processor-class-name="com.mycompany.batch.processfileabc.AbcJobLoader">
                  <thread-count>1</thread-count>
!                 <property key="pool-job-processor-key1">processor-value1</property>
              </pool-job-processor>
              <job-pool job-pool-class-name="org.jmonks.batchserver.framework.controller.pool.DefaultJobPool">
                  <property key="job-pool-size">50000</property>
              </job-pool>
!             <property key="pool-job-controller-restart">true</property>
          </job-controller>
      </job-config>
      <job-config>
!         <job-controller job-controller-class-name="org.jmonks.batchserver.framework.controller.basic.BasicJobController" 
!             job-controller-config-class-name="org.jmonks.batchserver.framework.config.BasicJobControllerConfig">
              <basic-job-processor basic-job-processor-class-name="com.mycompany.batch.processfilexyz.XyzProcessor">
                  <property key="basic-job-processor-key1">processor-value1</property>
              </basic-job-processor>
!             <property key="basic-job-controller-restart">true</property>
          </job-controller>
      </job-config>

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config batch-config.xml,1.1,1.2

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv13978

Modified Files:
	batch-config.xml 
Log Message:
Modifying the controller property allowed key values.

Index: batch-config.xml
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/batch-config.xml,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** batch-config.xml	28 Feb 2006 04:18:10 -0000	1.1
--- batch-config.xml	28 Feb 2006 04:22:25 -0000	1.2
***************
*** 14,18 ****
                  <property key="job-pool-size">50000</property>
              </job-pool>
!             <property key="controller-restart">true</property>
          </job-controller>
          <job-logging-config>
--- 14,18 ----
                  <property key="job-pool-size">50000</property>
              </job-pool>
!             <property key="job-controller-restart">true</property>
          </job-controller>
          <job-logging-config>
***************
*** 24,30 ****
              controller-config-class-name="org.jmonks.batchserver.framework.config.BasicJobControllerConfig">
              <basic-job-processor basic-job-processor-class-name="com.mycompany.batch.processfilexyz.XyzProcessor">
!                 <property key="processor-key1">processor-value1</property>
              </basic-job-processor>
!             <property key="controller-restart">true</property>
          </job-controller>
      </job-config>
--- 24,30 ----
              controller-config-class-name="org.jmonks.batchserver.framework.config.BasicJobControllerConfig">
              <basic-job-processor basic-job-processor-class-name="com.mycompany.batch.processfilexyz.XyzProcessor">
!                 <property key="basic-job-processor-key1">processor-value1</property>
              </basic-job-processor>
!             <property key="job-controller-restart">true</property>
          </job-controller>
      </job-config>

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config batch-framework-config.xml,1.1,NONE

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv11645

Removed Files:
	batch-framework-config.xml 
Log Message:
Deleting the earlier configuration file.

--- batch-framework-config.xml DELETED ---

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config batch-config.xml,NONE,1.1 framework-config.xml,NONE,1.1 Logging.properties,NONE,1.1

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv11374

Added Files:
	batch-config.xml framework-config.xml Logging.properties 
Log Message:
Submitting the basic configuration files.

--- NEW FILE: framework-config.xml ---
<framework-config>
    <job-config-reader-config config-reader-class-name="org.jmonks.batchserver.framework.config.XMLJobConfigReader">
        <property key="config-file-absolute-location">/batchserver/config/batch-config.xml</property>
        <!-- 
        Following is the another way to configure the XML Job configuration.
        <property key="config-file-classpath-location">org.jmonks.batchserver.framework.config.batch-config.xml</property> 
        -->
    </job-config-reader-config>
    <repository-config repository-class-name="org.jmonks.batchserver.framework.DefaultRepository">
        <property key="repository-location">/batchserver/repository</property>
        <property key="repository-filename">batchserver_repository.db</property>
    </repository-config>
    <framework-logging-config>
        <log-file-location>/batchserver/logs</log-file-location>
        <job-package-base-name>com.mycompany.batch</job-package-base-name>
    </framework-logging-config>
    <mgmt-mntr-config mgmt-mntr-class-name="org.jmonks.batchserver.framework.mgmtmntr.DefaultMgmtMntrManager">
        <property key="port-range">15000-20000</property>
    </mgmt-mntr-config>
    <!-- 
    Following is the sample configuration to read the job configuration from the database.
    
    <job-config-reader-config config-reader-class-name="org.jmonks.batchserver.framework.config.DBJobConfigReader">
        <property key="config-db-jdbc-driver-class-name"></property>
        <property key="config-db-url">jdbc:oracle:thin@hostname:1521:instname</property>
        <property key="config-db-username">scott</property>
        <property key="config-db-password">tiger</property>
    </job-config-reader-config>     
    -->    
</framework-config>
--- NEW FILE: batch-config.xml ---
<?xml version="1.0" encoding="UTF-8"?>
<batch-config>
    <job-config job-name="process_file_abc">
        <job-controller controller-class-name="org.jmonks.batchserver.framework.controller.pool.PoolJobController" 
            controller-config-class-name="org.jmonks.batchserver.framework.config.PoolControllerConfig">
            <pool-job-loader pool-job-loader-class-name="com.mycompany.batch.processfileabc.AbcJobLoader">
                <property key="pool-job-loader-key1">loader-value1</property>
            </pool-job-loader>
            <pool-job-processor pool-job-processor-class-name="com.mycompany.batch.processfileabc.AbcJobLoader">
                <thread-count>1</thread-count>
                <property key="pool-job-processor-info1">processor-value1</property>
            </pool-job-processor>
            <job-pool job-pool-class-name="org.jmonks.batchserver.framework.controller.pool.DefaultJobPool">
                <property key="job-pool-size">50000</property>
            </job-pool>
            <property key="controller-restart">true</property>
        </job-controller>
        <job-logging-config>
            <logging-property-file>com.mycompany.batch.processfileabc.Logging</logging-property-file>
        </job-logging-config>
    </job-config>
    <job-config>
        <job-controller controller-class-name="org.jmonks.batchserver.framework.controller.basic.BasicJobController" 
            controller-config-class-name="org.jmonks.batchserver.framework.config.BasicJobControllerConfig">
            <basic-job-processor basic-job-processor-class-name="com.mycompany.batch.processfilexyz.XyzProcessor">
                <property key="processor-key1">processor-value1</property>
            </basic-job-processor>
            <property key="controller-restart">true</property>
        </job-controller>
    </job-config>
</batch-config>
--- NEW FILE: Logging.properties ---
############################################################################
#   Framework Logging Properties
############################################################################

########### Defining the handlers  #########################################
handlers = java.util.logging.FileHandler


########### File Handler properties ########################################
java.util.logging.FileHandler.pattern = /batchserver/logs/batch_framework.log
java.util.logging.FileHandler.limit = 100000
java.util.logging.FileHandler.count = 1
java.util.logging.FileHandler.formatter = java.util.logging.SimpleFormatter

########### Define the loggers #############################################
org.jmonks.level = FINE

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/pool - New directory

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv10357/pool

Log Message:
Directory /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool added to the repository

[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller - New directory

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv10060/controller

Log Message:
Directory /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller added to the repository

[Batchserver-cvs] batchserver/lib/concurrent concurrent_1.3.4.jar,NONE,1.1 readme.txt,NONE,1.1

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

Update of /cvsroot/batchserver/batchserver/lib/concurrent
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv23688

Added Files:
	concurrent_1.3.4.jar readme.txt 
Log Message:
Multithreading jars to be used in core framework

--- NEW FILE: concurrent_1.3.4.jar ---
(This appears to be a binary file; contents omitted.)

--- NEW FILE: readme.txt ---
This jar will be used in multithreading of the core framework. Since, we are using jdk 1.4, we need to get this one as a seperate library. This is bundled in JDK1.5. 

More information can be found at:

http://g.oswego.edu/dl/classes/EDU/oswego/cs/dl/util/concurrent/intro.html

[Batchserver-cvs] batchserver/lib/concurrent - New directory

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

Update of /cvsroot/batchserver/batchserver/lib/concurrent
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv23266/concurrent

Log Message:
Directory /cvsroot/batchserver/batchserver/lib/concurrent added to the repository

[Batchserver-cvs] batchserver/lib/db/db4o db4o_5.0.jar,NONE,1.1 readme.txt,NONE,1.1

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

Update of /cvsroot/batchserver/batchserver/lib/db/db4o
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv16697/lib/db/db4o

Added Files:
	db4o_5.0.jar readme.txt 
Log Message:
Submitting the object database jars.

--- NEW FILE: db4o_5.0.jar ---
(This appears to be a binary file; contents omitted.)

--- NEW FILE: readme.txt ---
This is the implemenation of object database. The latest version for java 1.4 is 5.0. 

Native query optimizer files are not included. In case, if we plan to use query optimizer,
we can copy those jars (required assosicate jars bloat and ant tools) and 
modify the manifest of query optimizer jar to refer db4o_5.0 jar.

This can be downloaded from www.db4o.com.

[Batchserver-cvs] batchserver/lib/db/db4o - New directory

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

Update of /cvsroot/batchserver/batchserver/lib/db/db4o
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv16287/db4o

Log Message:
Directory /cvsroot/batchserver/batchserver/lib/db/db4o added to the repository

[Batchserver-cvs] batchserver/lib/db - New directory

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

Update of /cvsroot/batchserver/batchserver/lib/db
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv16227/db

Log Message:
Directory /cvsroot/batchserver/batchserver/lib/db added to the repository