[Batchserver-cvs] batchserver/test/org/jmonks/batchserver/framework/repository RepositoryTest.java, 1.7, 1.8

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

Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv22240

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.7
retrieving revision 1.8
diff -C2 -d -r1.7 -r1.8
*** RepositoryTest.java	12 Sep 2006 04:09:02 -0000	1.7
--- RepositoryTest.java	12 Sep 2006 23:25:05 -0000	1.8
***************
*** 10,20 ****
  import java.util.ArrayList;
  import java.util.Calendar;
- import java.util.Date;
  import junit.framework.*;
  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;
  
  
--- 10,17 ----
  import java.util.ArrayList;
  import java.util.Calendar;
  import junit.framework.*;
  import org.jmonks.batchserver.framework.JobStatistics;
  import org.jmonks.batchserver.framework.config.*;
! 
  
  
***************
*** 97,163 ****
      }
  
-     /**
-      *  Test method to test the getJobStatistics API of repository.
-      */
-     public void testGetJobStatistics()
-     {
-         Repository repository=Repository.getRepository();
-         assertNotNull(repository);
-         
-         JobStatistics[] recvdStats=repository.getStatistics("not_valid_job_name");
-         assertNotNull(recvdStats);
-         assertEquals(0,recvdStats.length);
-         
-         String jobName="process_"+Calendar.getInstance().getTimeInMillis();
-         JobStatistics statistics1=this.getJobStatistics(jobName, Calendar.getInstance().getTime(), Calendar.getInstance().getTime() , 234,  5000);
-         JobStatistics statistics2=this.getJobStatistics(jobName, Calendar.getInstance().getTime(), Calendar.getInstance().getTime() , 236,  5004);        
-         boolean logged=repository.logStatistics(statistics1);
-         assertTrue(logged);
-         logged=repository.logStatistics(statistics2);
-         assertTrue(logged);
-         
-         recvdStats=repository.getStatistics(jobName);
-         assertNotNull(recvdStats);
-         assertEquals(2,recvdStats.length);
-         for(int i=0;i<recvdStats.length;i++)
-             System.out.println(recvdStats[i]);
-     }
-     
-     private JobStatistics getJobStatistics(String jobName,Date startTime,Date endTime,int memory,int records)
-     {
-         JobStatistics statistics=new JobStatistics(jobName);
-         statistics.setStartTime(startTime);
-         statistics.setEndTime(endTime);
-         statistics.setMaxMemeoryUsage(memory);
-         statistics.setRecordsProcessed(records);
-         
-         return statistics;
-     }
-     
      public void testJobDataTransfer()
      {
          Repository repository=Repository.getRepository();
          assertNotNull(repository);
  
          String id1="first_data";
-         String sourceJob="process_file_abc";
          String targetJob="process_file_xyz";
          
!         boolean sent=repository.sendDataToNextJob(id1, sourceJob, targetJob, Calendar.getInstance());
          assertTrue(sent);
!         Calendar cal1=(Calendar)repository.getDataFromPreviousJob(id1, sourceJob, targetJob);
          assertNotNull(cal1);
!         boolean cleared=repository.clearDataTransferredFromThisJob(sourceJob);
          assertTrue(cleared);
!         Calendar cal2=(Calendar)repository.getDataFromPreviousJob(id1, sourceJob, targetJob);
          assertNull(cal2);
  
!         sent=repository.sendDataToNextJob(id1, sourceJob, targetJob, Calendar.getInstance());
          assertTrue(sent);
!         sent=repository.sendDataToNextJob(id1, sourceJob, targetJob, new ArrayList());
          assertTrue(sent);        
!         ArrayList list=(ArrayList)repository.getDataFromPreviousJob(id1, sourceJob, targetJob);
          assertNotNull(cal1);
!         cleared=repository.clearDataTransferredFromThisJob(sourceJob);
          assertTrue(cleared);
      }
--- 94,123 ----
      }
  
      public void testJobDataTransfer()
      {
+         FrameworkConfig.RepositoryConfig config=FrameworkConfig.getInstance().getRepositoryConfig();
+         Repository.createRepository("process_file_abc", config);
          Repository repository=Repository.getRepository();
          assertNotNull(repository);
  
          String id1="first_data";
          String targetJob="process_file_xyz";
          
!         boolean sent=repository.sendDataToNextJob(id1, targetJob, Calendar.getInstance());
          assertTrue(sent);
!         Calendar cal1=(Calendar)repository.getDataFromPreviousJob(id1, targetJob);
          assertNotNull(cal1);
!         boolean cleared=repository.clearDataTransferredFromThisJob();
          assertTrue(cleared);
!         Calendar cal2=(Calendar)repository.getDataFromPreviousJob(id1, targetJob);
          assertNull(cal2);
  
!         sent=repository.sendDataToNextJob(id1, targetJob, Calendar.getInstance());
          assertTrue(sent);
!         sent=repository.sendDataToNextJob(id1, targetJob, new ArrayList());
          assertTrue(sent);        
!         ArrayList list=(ArrayList)repository.getDataFromPreviousJob(id1, targetJob);
          assertNotNull(cal1);
!         cleared=repository.clearDataTransferredFromThisJob();
          assertTrue(cleared);
      }
***************
*** 165,192 ****
      public void testJobMgmtMntrInfoHolder()
      {
          Repository repository=Repository.getRepository();
          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);
          
--- 125,146 ----
      public void testJobMgmtMntrInfoHolder()
      {
+         FrameworkConfig.RepositoryConfig config=FrameworkConfig.getInstance().getRepositoryConfig();
+         Repository.createRepository("process_file_abc", config);        
          Repository repository=Repository.getRepository();
          assertNotNull(repository);
          
!         boolean unregistered=repository.unregisterJobMgmtMntrInfo();
          assertFalse(unregistered);
          
!         boolean registered=repository.registerJobMgmtMntrInfo(Calendar.getInstance());
          assertTrue(registered);
!         unregistered=repository.unregisterJobMgmtMntrInfo();
          assertTrue(unregistered);
  
!         registered=repository.registerJobMgmtMntrInfo(Calendar.getInstance());
          assertTrue(registered);        
!         registered=repository.registerJobMgmtMntrInfo(new ArrayList());
          assertTrue(registered);
!         unregistered=repository.unregisterJobMgmtMntrInfo();
          assertTrue(unregistered);