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