Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batch/framework/management
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv27472/framework/management
Modified Files:
JobManagementAgent.java
Log Message:
no message
Index: JobManagementAgent.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batch/framework/management/JobManagementAgent.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** JobManagementAgent.java 15 Sep 2006 20:07:01 -0000 1.1
--- JobManagementAgent.java 19 Sep 2006 00:05:52 -0000 1.2
***************
*** 68,72 ****
* Tells whether the agent has been stopped or not.
*/
! private boolean stopped=false;
private static Logger logger=Logger.getLogger(JobManagementAgent.class);
--- 68,72 ----
* Tells whether the agent has been stopped or not.
*/
! private boolean stopped=true;
private static Logger logger=Logger.getLogger(JobManagementAgent.class);
***************
*** 129,134 ****
if(this.started)
throw new IllegalStateException("job management agent has been already started.");
! if(this.stopped)
! throw new IllegalStateException("job management agent has been already stopped.");
if(jobContext==null)
--- 129,134 ----
if(this.started)
throw new IllegalStateException("job management agent has been already started.");
! if(!this.stopped)
! throw new IllegalStateException("job management agent has not been stopped.");
if(jobContext==null)
***************
*** 178,186 ****
logger.debug("Successfully registered the connector server with the job name");
this.started=true;
}
else
{
logger.error("Unable to register the jmx connector server using job connector helper");
! this.started=false;
}
}
--- 178,188 ----
logger.debug("Successfully registered the connector server with the job name");
this.started=true;
+ this.stopped=false;
}
else
{
logger.error("Unable to register the jmx connector server using job connector helper");
! this.started=false;
! this.stopped=false;
}
}
***************
*** 239,244 ****
if(!this.started)
! throw new IllegalStateException("Job management agent has not been started.");
!
if(this.stopped)
throw new IllegalStateException("Job management agent has been stopped already.");
--- 241,245 ----
if(!this.started)
! throw new IllegalStateException("Job management agent has not been started.");
if(this.stopped)
throw new IllegalStateException("Job management agent has been stopped already.");
***************
*** 256,259 ****
--- 257,261 ----
this.jobConnectorHelper.unregisterConnectorServer(jobContext);
this.stopped=true;
+ this.started=false;
logger.debug("unregistered the jmx connector server from lookup location");
}
|
