batchserver-cvs

[Suresh <sur...@us...>]

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