[Batchserver-cvs] batchserver/test/org/jmonks/batchserver/framework/controller/basic TestBasicJobP
Brought to you by:
suresh_pragada
From: Suresh <sur...@us...> - 2006-09-06 22:09:03
|
Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/controller/basic In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv14002 Modified Files: TestBasicJobProcessor.java Log Message: no message Index: TestBasicJobProcessor.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/controller/basic/TestBasicJobProcessor.java,v retrieving revision 1.4 retrieving revision 1.5 diff -C2 -d -r1.4 -r1.5 *** TestBasicJobProcessor.java 5 Sep 2006 18:16:20 -0000 1.4 --- TestBasicJobProcessor.java 6 Sep 2006 22:09:01 -0000 1.5 *************** *** 23,38 **** private static Logger logger=Logger.getLogger(TestBasicJobProcessor.class); ! /** Creates a new instance of TestBasicJobProcessor */ ! public TestBasicJobProcessor() ! { ! logger.error("TestBasicJobProcessor has been initialized"); ! } ! ! public void cleanup() { ! logger.error("TestBasicJobProcessor cleanup has been called"); } ! public int getProcessedCount() { return 10; --- 23,36 ---- private static Logger logger=Logger.getLogger(TestBasicJobProcessor.class); ! public TestBasicJobProcessor() { ! logger.error("Error :: TestBasicJobProcessor has been initialized"); ! logger.info("Info :: TestBasicJobProcessor has been initialized"); ! logger.debug("Debug :: TestBasicJobProcessor has been initialized"); ! logger.fatal("Fatal :: TestBasicJobProcessor has been initialized"); ! logger.warn("Warn :: TestBasicJobProcessor has been initialized"); } ! public int getProcessedRecordsCount() { return 10; *************** *** 41,95 **** public Object getProcessorState() { ! return "Running"; ! } ! ! public int getTotalCount() ! { ! return 20; ! } ! ! public void initialize(java.util.Map configProps) ! { ! logger.error("TestBasicJobProcessor initalize has been called"); ! logger.error("Called with the map = " + configProps); ! } ! ! public ErrorCode process() ! { ! return ErrorCode.JOB_CONFIGURATION_ERROR; ! } ! ! public boolean resume() ! { ! logger.error("TestBasicJobProcessor resume has been called"); ! return false; ! } ! ! public boolean stop() ! { ! logger.error("TestBasicJobProcessor stop has been called"); ! return false; ! } ! ! public boolean suspend() ! { ! logger.error("TestBasicJobProcessor suspend has been called"); ! return false; ! } ! ! public int getProcessedRecordsCount() ! { ! return 0; } public int getTotalRecordsCount() { ! return 0; } public ErrorCode process(java.util.Map configProps) { ! return null; } - } --- 39,53 ---- public Object getProcessorState() { ! return "RUNNING"; } public int getTotalRecordsCount() { ! return 50; } public ErrorCode process(java.util.Map configProps) { ! return ErrorCode.createErrorCode(10001, "This is my error message."); } } |