[Batchserver-cvs] batchserver/test/org/jmonks/batchserver/framework/repository RepositoryTest.java,1
Brought to you by:
suresh_pragada
From: Suresh <sur...@us...> - 2006-03-17 23:33:04
|
Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv7885 Modified Files: RepositoryTest.java Log Message: no message Index: RepositoryTest.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/RepositoryTest.java,v retrieving revision 1.2 retrieving revision 1.3 diff -C2 -d -r1.2 -r1.3 *** RepositoryTest.java 17 Mar 2006 22:36:39 -0000 1.2 --- RepositoryTest.java 17 Mar 2006 23:32:59 -0000 1.3 *************** *** 14,17 **** --- 14,20 ---- import org.jmonks.batchserver.framework.JobStatistics; import org.jmonks.batchserver.framework.config.*; + import org.jmonks.batchserver.framework.controller.JobController; + import org.jmonks.batchserver.framework.controller.basic.BasicJobController; + import org.jmonks.batchserver.framework.controller.pool.PoolJobController; *************** *** 39,45 **** public static Test suite() { ! //TestSuite suite = new TestSuite(RepositoryTest.class); ! TestSuite suite=new TestSuite(); ! suite.addTest(new RepositoryTest("testJobDataTransfer")); return suite; } --- 42,48 ---- public static Test suite() { ! TestSuite suite = new TestSuite(RepositoryTest.class); ! //TestSuite suite=new TestSuite(); ! //suite.addTest(new RepositoryTest("testJobControllerHolder")); return suite; } *************** *** 178,181 **** --- 181,213 ---- public void testJobMgmtMntrInfoHolder() { + FrameworkConfig frameworkConfig=FrameworkConfig.getInstance(); + assertNotNull(frameworkConfig); + FrameworkConfig.RepositoryConfig repositoryConfig=frameworkConfig.getRepositoryConfig(); + assertNotNull(repositoryConfig); + Repository repository=Repository.getRepository(repositoryConfig); + assertNotNull(repository); + + String jobName="process_file_abc"+Calendar.getInstance().getTimeInMillis(); + + Object object=repository.lookupJobMgmtMntrInfo(jobName); + assertNull(object); + boolean unregistered=repository.unregisterJobMgmtMntrInfo(jobName); + assertFalse(unregistered); + + boolean registered=repository.registerJobMgmtMntrInfo(jobName, Calendar.getInstance()); + assertTrue(registered); + Calendar cal1=(Calendar)repository.lookupJobMgmtMntrInfo(jobName); + assertNotNull(cal1); + unregistered=repository.unregisterJobMgmtMntrInfo(jobName); + assertTrue(unregistered); + + registered=repository.registerJobMgmtMntrInfo(jobName, Calendar.getInstance()); + assertTrue(registered); + registered=repository.registerJobMgmtMntrInfo(jobName, new ArrayList()); + assertTrue(registered); + ArrayList list=(ArrayList)repository.lookupJobMgmtMntrInfo(jobName); + assertNotNull(cal1); + unregistered=repository.unregisterJobMgmtMntrInfo(jobName); + assertTrue(unregistered); } *************** *** 183,186 **** --- 215,247 ---- public void testJobControllerHolder() { + FrameworkConfig frameworkConfig=FrameworkConfig.getInstance(); + assertNotNull(frameworkConfig); + FrameworkConfig.RepositoryConfig repositoryConfig=frameworkConfig.getRepositoryConfig(); + assertNotNull(repositoryConfig); + Repository repository=Repository.getRepository(repositoryConfig); + assertNotNull(repository); + + String jobName="process_file_abc"+Calendar.getInstance().getTimeInMillis(); + + JobController controller=repository.loadController(jobName); + assertNull(controller); + boolean released=repository.releaseController(jobName); + assertFalse(released); + + boolean saved=repository.saveController(jobName, new PoolJobController(null)); + assertTrue(saved); + controller=(JobController)repository.loadController(jobName); + assertNotNull(controller); + released=repository.releaseController(jobName); + assertTrue(released); + + saved=repository.saveController(jobName, new PoolJobController(null)); + assertTrue(saved); + saved=repository.saveController(jobName, new BasicJobController()); + assertTrue(saved); + BasicJobController basicController=(BasicJobController)repository.loadController(jobName); + assertNotNull(basicController); + released=repository.releaseController(jobName); + assertTrue(released); } |