testasyncprimitive.java

一个很好的微工作流内核

/*
 * 	 
 *  Copyright (c) 2002, 2003 Dragos Manolescu ([e-mail])
 * 
 *  See the LICENSE file for licensing information.
 */

package com.microworkflow.test;

import junit.framework.Test;
import junit.framework.TestSuite;

import com.microworkflow.execution.*;
import com.microworkflow.process.*;

public class TestAsyncPrimitive extends TestActivity {

	public TestAsyncPrimitive(String arg0) {
		super(arg0);
	}
	public static void main(String[] args) {
		junit.swingui.TestRunner.run(TestAsyncPrimitive.class);
	}
	public static Test suite() {
		return new TestSuite(TestAsyncPrimitive.class);
	}
	public void testAsyncPrimitive() {
		AsyncPrimitive p = new AsyncPrimitive(O1_KEY,"result1", new Performer() {
			public Object execute() {
				synchronized(this) {
					try {
						wait(2000);
					} catch (InterruptedException e) {
						;
					}
				}
				if (context.containsKey(targetKey)) {
					DomainObject domainObject = (DomainObject) getTarget();
					return domainObject.concat((String) get("argument1"));
				}
				return null;
			}
		});
		wc = executeWorkflow(p);
		String expectedResult = "this is a string".concat("first argument");
		assertEquals(
			"Strings not equal",
			true,
			expectedResult.equalsIgnoreCase((String) wc.get("result1")));
	}

}