[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/management JobConnectorHelper.java, 1.1, 1.2 JobManagementAgent.java, 1.3, 1.4

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

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

Modified Files:
	JobConnectorHelper.java JobManagementAgent.java 
Log Message:
no message

Index: JobManagementAgent.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/management/JobManagementAgent.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** JobManagementAgent.java	29 Aug 2006 02:01:33 -0000	1.3
--- JobManagementAgent.java	6 Sep 2006 22:07:43 -0000	1.4
***************
*** 14,18 ****
  import org.jmonks.batchserver.framework.controller.JobController;
  
- 
  /**
   * <p>
--- 14,17 ----
***************
*** 144,148 ****
                  logger.debug("Got the jmx connector server from the implementation");                            
              }
!             
              JobMonitorMBean monitorBean=new JobMonitor(jobController);
              JobManagerMBean managerBean=new JobManager(jobController);
--- 143,150 ----
                  logger.debug("Got the jmx connector server from the implementation");                            
              }
! 
!             /**
!              * Create the mbeans and register them with this mbean server.
!              */
              JobMonitorMBean monitorBean=new JobMonitor(jobController);
              JobManagerMBean managerBean=new JobManager(jobController);
***************
*** 158,168 ****
              mbeanServer.registerMBean(monitorBean, monitorBeanObjectName);
              mbeanServer.registerMBean(managerBean,  managerBeanObjectName);
- 
              /**
!              * Create the mbeans and register them with this mbean server.
               */
              boolean registered=this.jobConnectorHelper.registerConnectorServer(jobName,this.jmxConnectorServer);
              if(registered)
              {
                  this.started=true;
              }
--- 160,171 ----
              mbeanServer.registerMBean(monitorBean, monitorBeanObjectName);
              mbeanServer.registerMBean(managerBean,  managerBeanObjectName);
              /**
!              *  Start the connector server and register it with the job name.
               */
+             this.jmxConnectorServer.start();
              boolean registered=this.jobConnectorHelper.registerConnectorServer(jobName,this.jmxConnectorServer);
              if(registered)
              {
+                 logger.debug("Successfully registered the connector server with the job name");
                  this.started=true;
              }
***************
*** 193,197 ****
              logger.error(exception.getMessage(),exception);            
          }
!         
  
          logger.trace("Exiting start");        
--- 196,204 ----
              logger.error(exception.getMessage(),exception);            
          }
!         catch(IOException exception)
!         {
!             exception.printStackTrace();
!             logger.error(exception.getMessage(),exception);            
!         }
  
          logger.trace("Exiting start");        
***************
*** 240,242 ****
--- 247,260 ----
          return this.stopped;
      }
+ 
+     /**
+      *  Tells whether the agent is running or not. This state needs to be queried
+      *  before trying to stop the agent.
+      *
+      *  @return Returns true if agent is running, false otherwise.
+      */
+     public boolean isRunning()
+     {
+         return this.started;
+     }
  }

Index: JobConnectorHelper.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/management/JobConnectorHelper.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** JobConnectorHelper.java	28 Mar 2006 04:55:17 -0000	1.1
--- JobConnectorHelper.java	6 Sep 2006 22:07:43 -0000	1.2
***************
*** 76,80 ****
      {        
          logger.trace("Entering getJobConnectorHelper");
!         if(jobConnectorHelper!=null)
          {
              FrameworkConfig.JobConnectorConfig jobConnectorConfig=FrameworkConfig.getInstance().getJobConnectorConfig();
--- 76,80 ----
      {        
          logger.trace("Entering getJobConnectorHelper");
!         if(jobConnectorHelper==null)
          {
              FrameworkConfig.JobConnectorConfig jobConnectorConfig=FrameworkConfig.getInstance().getJobConnectorConfig();