[Batchserver-cvs] batchserver/src/org/jmonks/batch/framework/management JobManagementAgent.java, 1
Brought to you by:
suresh_pragada
From: Suresh <sur...@us...> - 2006-09-19 00:05:58
|
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"); } |