_br-ode-1.X.svn/axis2-war/src/test/java/org/apache/ode/axis2/BpelActivityTest.java

package org.apache.ode.axis2;

import static org.testng.Assert.fail;

import org.apache.log4j.Logger;
import org.testng.annotations.Test;

public class BpelActivityTest extends Axis2TestBase {
	@Test(dataProvider="configs")
    public void testThrowOnEvent() throws Exception {
		final String bundleName = "TestThrowOnEvent";
        // deploy the required service
        server.deployService(DummyService.class.getCanonicalName());
        if (server.isDeployed(bundleName)) server.undeployProcess(bundleName);
        server.deployProcess(bundleName);

        new Thread() {
        	public void run() {
        		try {
        			Thread.sleep(2000);
        			String response = server.sendRequestFile("http://localhost:8888/ode/processes/OnEventCorrelation/",
                            bundleName, "testRequest.soap");
        			Logger.getLogger(BpelActivityTest.class).debug("!!! : " + response);
        		} catch( Exception e ) {
        			fail(e.getMessage());
        		}
        	}
        }.start();

//        new Thread() {
//        	public void run() {
//        		try {
//        			Thread.sleep(6000);
//        			String response = server.sendRequestFile("http://localhost:8888/ode/processes/OnEventCorrelation/",
//                            bundleName, "testRequest.soap");
//        			Logger.getLogger(BpelActivityTest.class).debug("!!!SEAN : " + response);
//        		} catch( Exception e ) {
//        			fail(e.getMessage());
//        		}
//        	}
//        }.start();

        try {
            String response = server.sendRequestFile("http://localhost:8888/ode/processes/OnEventCorrelation/",
                    bundleName, "testRequest.soap");
            Logger.getLogger(BpelActivityTest.class).debug("!!! : " + response);
            
//            assertTrue(response.contains("helloResponse") && response.contains("Something went wrong. Fortunately, it was meant to be."));
        } finally {
//            server.undeployProcess(bundleName);
        }
        
        Thread.sleep(6000);
    }
}