definitionservicetest.java

一个java工作流引擎

package org.jbpm.service;

import java.util.*;
import java.util.Collection;
import java.util.Iterator;
import junit.framework.*;
import org.jbpm.*;
import org.jbpm.model.definition.Definition;

public class DefinitionServiceTest extends TestCase {
  
  public static TestHelper helper = new TestHelper();
  private ExecutionService executionService = helper.getExecutionService();
  
  static {
    deployProcess();
  }
  
  private static void deployProcess() {
		Map files = new HashMap();
    files.put( "classes/org/jbpm/service/DefinitionServiceTest.class", "org/jbpm/service/DefinitionServiceTest.class" );
    helper.deployProcess( "process/completeprocess.xml", files );
	}

	public void testCompleteProcessDeployment() {
    // retrieve the definition
    assertNotNull(executionService.getLatestDefinition( "complete process"));
  }
  
  public void testGetLatesDefinition() throws Exception {
    Collection latestDefinitions = executionService.getLatestDefinitions();
    int numberOfDefinitions = latestDefinitions.size();
    
    int originalVersion = -1;
    Iterator iter = latestDefinitions.iterator();
    while ( iter.hasNext() ) {
      Definition completeProcess = (Definition)iter.next();
      if ( completeProcess.getName().equals( "complete process") ) {
        originalVersion = completeProcess.getVersion().intValue(); 
      }
    }

    deployProcess();
    
    latestDefinitions = executionService.getLatestDefinitions();
    assertEquals( numberOfDefinitions, latestDefinitions.size() );
    
    iter = latestDefinitions.iterator();
    while ( iter.hasNext() ) {
      Definition completeProcess = (Definition)iter.next();
      if ( completeProcess.getName().equals( "complete process") ) {
        assertEquals( new Integer( originalVersion + 1 ), completeProcess.getVersion() ); 
      }
    }
  }
}