batchserver-cvs

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batch/framework
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv3163

Modified Files:
	Main.java 
Log Message:
no message

Index: Main.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batch/framework/Main.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** Main.java	19 Sep 2006 00:05:52 -0000	1.2
--- Main.java	19 Sep 2006 22:51:39 -0000	1.3
***************
*** 8,12 ****
  import org.jmonks.batch.framework.config.JobConfig;
  import org.jmonks.batch.framework.config.JobConfigFactory;
- import org.jmonks.batch.framework.controller.JobController;
  import org.jmonks.batch.framework.management.JobManagementAgent;
  
--- 8,11 ----
***************
*** 122,130 ****
                      jobContext=createJobContext(jobConfig, configMap, frameworkCreator);
                      logger.debug("Creating the job controller");
!                     JobController jobController=JobController.getJobController(jobContext);
                      logger.debug("Retrieving the management agent");
!                     jobManagementAgent=JobManagementAgent.getJobManagementAgent();
                      logger.debug("Registering the controller with the management agent");
!                     jobManagementAgent.start(jobContext, jobController, frameworkCreator);
                      logger.error("Starting the controller");
                      returnCode=jobController.process();
--- 121,129 ----
                      jobContext=createJobContext(jobConfig, configMap, frameworkCreator);
                      logger.debug("Creating the job controller");
!                     JobController jobController=JobController.createJobController(jobContext, frameworkCreator);
                      logger.debug("Retrieving the management agent");
!                     jobManagementAgent=JobManagementAgent.createJobManagementAgent(jobContext, frameworkCreator);
                      logger.debug("Registering the controller with the management agent");
!                     jobManagementAgent.start(jobController);
                      logger.error("Starting the controller");
                      returnCode=jobController.process();
***************
*** 167,171 ****
              logger.debug("Unregistering the controller with the management agent");
              if(jobManagementAgent!=null && jobManagementAgent.isRunning())
!                 jobManagementAgent.stop(jobContext, returnCode, frameworkCreator); 
          }
          logger.error("Exiting process = " + returnCode);
--- 166,170 ----
              logger.debug("Unregistering the controller with the management agent");
              if(jobManagementAgent!=null && jobManagementAgent.isRunning())
!                 jobManagementAgent.stop(returnCode); 
          }
          logger.error("Exiting process = " + returnCode);