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

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

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

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.8
retrieving revision 1.9
diff -C2 -d -r1.8 -r1.9
*** RepositoryTest.java	12 Sep 2006 23:25:05 -0000	1.8
--- RepositoryTest.java	13 Sep 2006 04:51:14 -0000	1.9
***************
*** 3,23 ****
   * JUnit based test
   *
!  * Created on March 14, 2006, 3:54 PM
   */
  
  package org.jmonks.batchserver.framework.repository;
  
- import java.util.ArrayList;
- import java.util.Calendar;
  import junit.framework.*;
- import org.jmonks.batchserver.framework.JobStatistics;
  import org.jmonks.batchserver.framework.config.*;
  
  
- 
- 
  /**
   *
!  * @author w951h8m
   */
  public class RepositoryTest extends TestCase
--- 3,18 ----
   * JUnit based test
   *
!  * Created on September 12, 2006, 10:16 PM
   */
  
  package org.jmonks.batchserver.framework.repository;
  
  import junit.framework.*;
  import org.jmonks.batchserver.framework.config.*;
  
  
  /**
   *
!  * @author Suresh Pragada
   */
  public class RepositoryTest extends TestCase
***************
*** 39,45 ****
      public static Test suite()
      {
!         TestSuite suite = new TestSuite(RepositoryTest.class);
!         //TestSuite suite=new TestSuite();
!         //suite.addTest(new RepositoryTest("testJobControllerHolder"));
          return suite;
      }
--- 34,40 ----
      public static Test suite()
      {
!         TestSuite suite = new TestSuite();
!         suite.addTest(new RepositoryTest("testInstantiation"));
!         suite.addTest(new RepositoryTest("testCreateReport"));
          return suite;
      }
***************
*** 69,178 ****
      }
      
!     /**
!      * Test to make sure this is not returning null.
!      */
!     public void testGetRepository()
!     {
!         Repository repository=Repository.getRepository();
!         assertNotNull(repository);
!     }
!     
!     /**
!      *  Test method to test the logJobStatistics API of repository.
!      */
!     public void testLogJobStatistics()
!     {
!         Repository repository=Repository.getRepository();
!         assertNotNull(repository);
!         JobStatistics statistics=new JobStatistics("process_file_xyz");
!         statistics.setStartTime(Calendar.getInstance().getTime());
!         statistics.setEndTime(Calendar.getInstance().getTime());
!         statistics.setMaxMemeoryUsage(1000);
!         statistics.setRecordsProcessed(50000);
!         boolean logged=repository.logStatistics(statistics);
!         assertTrue(logged);
!     }
! 
!     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);
!     }
!     
!     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);
!         
      }
      
-     public void testJobControllerHolder()
-     {
- /*        Repository repository=Repository.getRepository();
-         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());
-         assertTrue(saved);
-         controller=(JobController)repository.loadController(jobName);
-         assertNotNull(controller);
-         released=repository.releaseController(jobName);
-         assertTrue(released);
- 
-         saved=repository.saveController(jobName, new PoolJobController());
-         assertTrue(saved);        
-         saved=repository.saveController(jobName, new BasicJobController());
-         assertTrue(saved);
-         BasicJobController basicController=(BasicJobController)repository.loadController(jobName);
-         assertNotNull(basicController);
-         released=repository.releaseController(jobName);
-         assertTrue(released);  */
-         
-     }
  }
--- 64,94 ----
      }
      
!     public void testCreateReport()
      {
!         FrameworkConfig.RepositoryConfig repositoryConfig=FrameworkConfig.getInstance().getRepositoryConfig();
!         if(repositoryConfig!=null)
!         {
!             Repository.createRepository("process_file_abc", repositoryConfig);
!             try
!             {
!                 Repository.createRepository("process_file_abc", repositoryConfig);
!                 fail("No shout when trying to create the repository second time.");
!             }
!             catch(IllegalStateException exception)
!             {
!             }
!         }
!         else
!         {
!             try
!             {
!                 Repository.createRepository("process_file_abc", null);
!                 fail("Repository has been created with no repository config.");
!             }
!             catch(ConfigurationException exception)
!             {
!             }
!         }
      }
      
  }