serializationtest.java

一个java工作流引擎

package org.jbpm.service;

import java.io.*;
import org.jbpm.*;
import org.jbpm.model.definition.*;
import org.jbpm.model.execution.impl.*;
import org.jbpm.model.log.*;
import junit.framework.*;

public class SerializationTest extends TestCase {

  public static TestHelper helper = new TestHelper();
  private ExecutionService executionService = helper.getExecutionService();
  
  static {
    helper.deployProcess( "process/stateprocess.xml" );
  }
  
  public void testStateProcess() throws Exception {
    // retrieve the definition
    Definition definition = executionService.getLatestDefinition( "the state process" );
    
    // start a process instance
    InvocationLog invocationLog = executionService.startProcessInstance( "testrunner", definition.getId() );
    checkSerializability( invocationLog.getProcessInstance().getDefinition() );
    checkSerializability( invocationLog.getProcessInstance() );
    checkSerializability( invocationLog );
    ProcessInstanceImpl pi = (ProcessInstanceImpl) invocationLog.getProcessInstance();
    Long tokenId = pi.getRoot().getId();

    invocationLog = executionService.endOfState( "testrunner", tokenId );
    checkSerializability( invocationLog );
  }
  
  public void checkSerializability( Object o ) throws IOException {
    ObjectOutputStream os = new ObjectOutputStream( new ByteArrayOutputStream() );
    os.writeObject( o );
  }
  
}