Modified: incubator/ode/scratch/bpe/src/test/java/org/apache/ode/bpe/test/BPELTests.java URL: http://svn.apache.org/viewvc/incubator/ode/scratch/bpe/src/test/java/org/apache/ode/bpe/test/BPELTests.java?rev=417301&r1=417300&r2=417301&view=diff ============================================================================== --- incubator/ode/scratch/bpe/src/test/java/org/apache/ode/bpe/test/BPELTests.java (original) +++ incubator/ode/scratch/bpe/src/test/java/org/apache/ode/bpe/test/BPELTests.java Mon Jun 26 15:00:26 2006 @@ -1,658 +1,693 @@ -/* - * Copyright 2006 The Apache Software Foundation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. -*/ -/* - * Created on Jan 26, 2004 - * - * To change the template for this generated file go to - * Window>Preferences>Java>Code Generation>Code and Comments - */ -package org.apache.ode.bpe.test; - -import java.util.Iterator; - -import org.apache.ode.bpe.cc.client.InstanceState; -import org.apache.ode.bpe.cc.data.DefinitionData; -import org.apache.ode.bpe.cc.data.InstanceData; - - -/** - * @author charper - * - * To change the template for this generated type comment go to - * Window>Preferences>Java>Code Generation>Code and Comments - */ -public class BPELTests extends BPELTester { - - - - /** - * Constructor for BPELTests. - * @param arg0 - */ - public BPELTests(String arg0) { - super(arg0); - } - - - - public void testTest1() throws Exception { - - bpelFile = bpelTestsDir+"test1/bpelTest1.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test1/data1_1.txt",bpelTestsDir+"test1/data1_2.txt", - bpelTestsDir+"test1/data1_3.txt",bpelTestsDir+"test1/data1_4.txt",bpelTestsDir+"test1/data1_5.txt", - bpelTestsDir+"test1/data1_6.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: test1Process complete\n"+ -"Part \"replyText\" value: Event Start Test1.1 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> test1Process complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: test1Process complete\n"+ -"Part \"replyText\" value: Event Start Test1.2 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> test1Process complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: test1Process complete\n"+ -"Part \"replyText\" value: Event Start Test1.3 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> test1Process complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: test1Process complete\n"+ -"Part \"replyText\" value: Event Start Test1.4 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> test1Process complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: test1Process complete\n"+ -"Part \"replyText\" value: Event Start Test1.5 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> case max: set loop iterations = 10 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> 7 -> 8 -> 9 -> 10 -> 11 -> test1Process complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: test1Process complete\n"+ -"Part \"replyText\" value: Event Start Test1.6 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> otherwise: set loop iterations = 0 -> test loop iterations -> test1Process complete\n"; - - assertTrue(go(0, null)); - } - - public void testTest10() throws Exception { - bpelFile = bpelTestsDir+"test10/bpelTest10.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test10/data10_1.txt",bpelTestsDir+"test10/data10_3.txt", - bpelTestsDir+"test10/data10_4.txt",bpelTestsDir+"test10/data10_2.txt"}; - expectedResponse= -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test10.1 -> block for next message -> received event on port test10_3PT -> received event on port test10_4PT -> process complete\n"; - assertTrue(go(0, null)); - } - - - public void testTest12() throws Exception { - bpelFile = bpelTestsDir+"test12/bpelTest12.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test12/data12_1.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: Start Test12\n"+ -"Part \"replyText\" value: pass\n"; - assertTrue(go(0, null)); - } - - public void testTest13() throws Exception { - bpelFile = bpelTestsDir+"test13/bpelTest13.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test13/data13_1.txt"}; - expectedResponse ="Fault Message:null\n"+ -"Part \"replyID\" value: Test13\n"+ -"Part \"replyText\" value: pass\n"; - assertTrue(go(0, null)); - } - - public void testTest14() throws Exception { - bpelFile = bpelTestsDir+"test14/bpelTest14.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test14/data14_1.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: Test14\n"+ -"Part \"replyText\" value: pass\n"; - assertTrue(go(0, null)); - } - - public void testTest15() throws Exception { - bpelFile = bpelTestsDir+"test15/bpelTest15.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test15/data15_1.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: Start Test15\n"+ -"Part \"replyText\" value: pass\n"; - assertTrue(go(0, null)); - } - - - public void testTest2() throws Exception { - bpelFile = bpelTestsDir+"test2/bpelTest2.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test2/data2_1.txt",bpelTestsDir+"test2/data2_2.txt", - bpelTestsDir+"test2/data2_3.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test2.1 -> throw testFault -> caught testFault -> process complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: caught fault with catchAll\n"+ -"Part \"replyText\" value: Event Start Test2.2 -> throw unknown fault -> caught fault with catchAll\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test2.3 -> process complete\n"; - assertTrue(go(0, null)); - } - - public void testTest3() throws Exception { - bpelFile = bpelTestsDir+"test3/bpelTest3.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test3/data3_1.txt",bpelTestsDir+"test3/data3_2.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test3.1 -> begin fault test -> throw testFault -> caught testFault -> process complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test3.2 -> begin fault test -> throw unknown fault -> process complete\n"; - assertTrue(go(0, null)); - } - - - public void testTest5() throws Exception { - bpelFile = bpelTestsDir+"test5/bpelTest5.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test5/data5_1_1.txt",bpelTestsDir+"test5/data5_1_2.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test5.1 -> loop on receive until message includes requestEnd = yes -> received message -> process complete\n"; - assertTrue(go(0, null)); - } - - public void testTest6() throws Exception { - bpelFile = bpelTestsDir+"test6/bpelTest6.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test6/data6_1.txt",bpelTestsDir+"test6/data6_2.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test6.1 -> pick branch one invoked -> process complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test6.2 -> pick branch two invoked -> process complete\n"; - assertTrue(go(0, null)); - } - - public void testTest7() throws Exception { - bpelFile = bpelTestsDir+"test7/bpelTest7.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test7/data7_1.txt",bpelTestsDir+"test7/data7_3.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test7.1 -> block for next message -> pick branch two invoked -> process complete\n"; - assertTrue(go(0, null)); - } - - - public void testTest8() throws Exception { - bpelFile = bpelTestsDir+"test8/bpelTest8.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test8/data8_1.txt",bpelTestsDir+"test8/data8_3.txt", - bpelTestsDir+"test8/data8_4.txt",bpelTestsDir+"test8/data8_2.txt",bpelTestsDir+"test8/data8_2.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test8.1 -> block for next message -> received event on port test8_3PT -> received event on port test8_4PT -> block for next message -> process complete\n"; - assertTrue(go(0, null)); - } - - public void testTest9() throws Exception { - bpelFile = bpelTestsDir+"test9/bpelTest9.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test9/data9_1.txt",bpelTestsDir+"test9/data9_2_1.txt", - bpelTestsDir+"test9/data9_2_2.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test9.1 -> loop on pick until message includes requestEnd = yes -> pick branch one invoked -> pick branch two invoked -> process complete\n"; - assertTrue(go(0, null)); - } - - public void testTest16() throws Exception { - bpelFile = bpelTestsDir+"test16/bpelTest16.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test16/data16_1.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n" + -"Part \"replyText\" value: Event Start Test16.1 -> caught uninitializedVariable -> process complete\n"; - - - assertTrue(go(0, null)); - } - - public void testTest17() throws Exception { - bpelFile = bpelTestsDir+"test17/bpelTest17.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test17/data17_1.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: process complete\n"+ -"Part \"replyText\" value: Event Start Test17.1 -> caught FaultMessage -> fault text one -> process complete\n"; - assertTrue(go(0, null)); - } - - public void testTestBPChain() throws Exception { - bpelFile = bpelTestsDir+"testBPChain/bpelTestBPChain.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testBPChain/data1_1.txt"}; - expectedResponse = "Fault Message:null.*response1.*some reply text.*"; -/*"Fault Message:null\n"+ -"Part \"responses\" value: <.xml version=\"1.0\" encoding=\"UTF-8\".>\n"+ -"<response1>response1</response1>\n"+ -"Part \"replyID\" value: a reply ID\n"+ -"Part \"replyText\" value: some reply text\n";*/ - - assertTrue(go(0, null)); - } - -/* public void testTimer1() throws Exception { - bpelFile = "testTimer1/bpelTestTimer1.jar"; - threadNumber=1; - msgFiles = new String [] {"testTimer1/timer1Data.txt","testTimer1/timer1Data.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"replyText\" value: PT3SPT7S\n"; - assertTrue(go(30000)); - } - - public void testTimer2() throws Exception { - bpelFile = "testTimer2/bpelTestTimer2.jar"; - threadNumber=1; - msgFiles = new String [] {"testTimer2/timer2Data.txt","testTimer2/timer2Data.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"replyText\" value: TESTPT7S\n"; - assertTrue(go(20000)); - } - - public void testTimer3() throws Exception { - bpelFile = "testTimer3/bpelTestTimer3.jar"; - threadNumber=1; - msgFiles = new String [] {"testTimer3/timer3Data.txt"}; - expectedResponse = -"Fault Message:null\n"; - assertTrue(go(1000)); - }*/ - - public void testTerminate() throws Exception { - bpelFile = bpelTestsDir+"testTerminate/bpelTestTerminate.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testTerminate/terminate1Data.txt"}; - expectedResponse = -"Fault Message:null\n"; - assertTrue(go(0, null)); - } - - public void testTerminateTest5() throws Exception { - bpelFile = bpelTestsDir+"test5/bpelTest5.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"test5/data5_1_1.txt"}; //,"test5/data5_1_2.txt"}; - expectedResponse = -"Fault Message:null\n";//+ -//"Fault Message:null\n"+ -//"Part \"replyID\" value: process complete\n"+ -//"Part \"replyText\" value: Event Start Test5.1 -> loop on receive until message includes requestEnd = yes -> received message -> process complete\n"; - //assertTrue( - go(0, null);//); - - Iterator it = ccs.getDefinitionData().iterator(); - while ( it.hasNext() ) { - DefinitionData dd = (DefinitionData)it.next(); - if ( dd.getName().equals("test5Process")) { - Iterator it2 = ccs.getInstancesData(dd.getID()).iterator(); - while ( it2.hasNext() ) { - InstanceData id = (InstanceData)it2.next(); - ccs.terminateInstance(id); - } - break; - } - } - - // look for the process agian - it = ccs.getDefinitionData().iterator(); - while ( it.hasNext() ) { - DefinitionData dd = (DefinitionData)it.next(); - if ( dd.getName().equals("test5Process")) { - Iterator it2 = ccs.getInstancesData(dd.getID()).iterator(); - while ( it2.hasNext() ) { - InstanceData id = (InstanceData)it2.next(); - if ( ! id.getState().toString().equals(InstanceState.FINISHED.toString()) ) { - assertTrue(false); - return; - } - } - } - } - assertTrue(true); - } - - - - public void testScopedCorrelationSets() throws Exception { - bpelFile = bpelTestsDir+"testScopedCorrelationSets/bpelTestScopedCorrelationSets.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testScopedCorrelationSets/data1.txt", - bpelTestsDir+"testScopedCorrelationSets/data2.txt",bpelTestsDir+"testScopedCorrelationSets/data3.txt"}; - expectedResponse = - "Fault Message:null\n"+ - "Fault Message:null\n"+ - "Fault Message:null\n"+ - "Part \"replyText\" value: corrl2\n"; - assertTrue(go(0, null)); - } - - public void testCatchForcedTermination() throws Exception { - bpelFile = bpelTestsDir+"testCatchForcedTerminate/bpelTestCatchForcedTerminate.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testCatchForcedTerminate/data1.txt", - bpelTestsDir+"testCatchForcedTerminate/data3.txt"}; - expectedResponse = - "Fault Message:null\n"+ - "Fault Message:null\n"+ - "Part \"replyText\" value: forcedTermination\n"; - assertTrue(go(0, null)); - } - - public void testFaultInCompensationHandler() throws Exception { - bpelFile = bpelTestsDir+"testFaultInCompensationHandler/bpelTestFaultInCompensationHandler.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testFaultInCompensationHandler/data1.txt", - bpelTestsDir+"testFaultInCompensationHandler/data3.txt"}; - expectedResponse = - "Fault Message:null\n"+ - "Fault Message:null\n"+ - "Part \"replyText\" value: msg1\n"; - assertTrue(go(0, null)); - } - - public void testFaultInFaultHandler() throws Exception { - bpelFile = bpelTestsDir+"testFaultInFaultHandler/bpelTestFaultInFaultHandler.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testFaultInFaultHandler/data1.txt"}; - expectedResponse = - "Fault Message:null\n"+ - "Part \"replyText\" value: ScopeOneTwoFaultHandler -> RootScopeFaultHandler\n"; - assertTrue(go(0, null)); - } - -/* public void testTimerOnAlarmAtRootScope() throws Exception { - bpelFile = "testTimerOnAlarmAtRootScope/bpelTestTimerOnAlarmAtRootScope.jar"; - threadNumber=1; - msgFiles = new String [] {"testTimerOnAlarmAtRootScope/timer1Data.txt","testTimerOnAlarmAtRootScope/timer1Data.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"replyText\" value: PT3SPT7S\n"; - assertTrue(go(30000)); - }*/ - - public void testOOBData() throws Exception { - bpelFile = bpelTestsDir+"testOOBData/bpelTestOOBData.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testOOBData/oOBData.txt",bpelTestsDir+"testOOBData/oOBData2.txt"}; - Object[] oobData = new Object[] {"junk",null}; - expectedResponse = - "Fault Message:null\n"+ - "Fault Message:null\n"+ - "Part \"replyText\" value: junk\n"; - assertTrue(go(0, oobData)); - } - - public void testNSDeploy() throws Exception { - bpelFile = bpelTestsDir+"testNSDeploy/bpelTestNSDeploy.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testNSDeploy/nSDeploy.txt"}; - expectedResponse = - "Fault Message:null\n"+ - "Part \"replyText\" value: PT7S\n"; - assertTrue(go(0, null)); - } - - public void testLocalInvoke() throws Exception { - bpelFile = bpelTestsDir+"testLocalInvoke/bpelTestLocalInvoke.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testLocalInvoke/localInvoke1.txt"}; - expectedResponse = - "Fault Message:null\n"+ - "Part \"replyText\" value: test\n"; - assertTrue(go(0, null)); - } - - public void testLinkInSwitch() throws Exception { - bpelFile = bpelTestsDir+"testLinkInSwitch/bpelTestLinkInSwitch.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testLinkInSwitch/dataLIS_1.txt",bpelTestsDir+"testLinkInSwitch/dataLIS_2.txt", - bpelTestsDir+"testLinkInSwitch/dataLIS_3.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Part \"replyID\" value: testLinkInSwitch complete\n"+ -"Part \"replyText\" value: Start TestLIS.1 -> case1 -> test switch link -> switch-case1 -> known-message -> testLinkInSwitch complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: testLinkInSwitch complete\n"+ -"Part \"replyText\" value: Start TestLIS.2 -> case2 -> test switch link -> switch-case2 -> known-message -> testLinkInSwitch complete\n"+ -"Fault Message:null\n"+ -"Part \"replyID\" value: testLinkInSwitch complete\n"+ -"Part \"replyText\" value: Start TestLIS.3 -> otherwise -> test switch link -> switch-otherwise -> unknown-message -> testLinkInSwitch complete\n"; - assertTrue(go(0, null)); - } - - public void testQts377278() throws Exception { - bpelFile = bpelTestsDir+"testQts377278/bpelTestQts377278.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testQts377278/data.txt"}; - expectedResponse = - "Fault Message:null\n"; - assertTrue(go(0, null)); - } - - public void testPartnerLinkAssign() throws Exception { - bpelFile = bpelTestsDir+"testPartnerLinkAssign/bpelTestPartnerLinkAssign.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testPartnerLinkAssign/data.txt"}; - expectedResponse = - "Fault Message:null\n"+ - "Part \"replyText\" value: partnerLinkDataInpartnerLinkDataOut\n"; - assertTrue(go(0, null)); - } - - public void testNestedSplits() throws Exception { - bpelFile = bpelTestsDir+"testNestedSplits/bpelTestNestedSplits.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testNestedSplits/links.props"}; - expectedResponse = - "Fault Message:null\n"+ - "Part \"InParam\" value: franklin\n"; - assertTrue(go(0, null)); - } - - public void testReplyWithFault() throws Exception { - bpelFile = bpelTestsDir+"testReplyWithFault/bpelTestReplyWithFault.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testReplyWithFault/dataReplyWithFault.txt"}; - expectedResponse = -"Fault Message:Fault Actor:null Fault Code:null Fault String:testFault\n"+ -"FaultPart \"faultID\" value: fault text one\n"+ -"FaultPart \"faultText\" value: Event Start Test ReplyWithFault -> caught FaultMessage -> fault text one\n\n"; - assertTrue(go(0, null)); - } - - public void testCorrlCmplx() throws Exception { - bpelFile = bpelTestsDir+"testCorrlCmplx/bpelTestCorrlCmplx.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testCorrlCmplx/msg1.txt", - bpelTestsDir+"testCorrlCmplx/msg2.txt", - bpelTestsDir+"testCorrlCmplx/msg3.txt"}; - expectedResponse = -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Fault Message:null\n"+ -"Part \"newParameter2\" value: cory\n"; - assertTrue(go(0, null)); - } - - public void testCorrlInvokeReply() throws Exception { - bpelFile = bpelTestsDir+"testCorrlInvokeReply/bpelTestCorrlInvokeReply.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testCorrlInvokeReply/msg1.txt", - bpelTestsDir+"testCorrlInvokeReply/msg2.txt", - bpelTestsDir+"testCorrlInvokeReply/msg3.txt", - bpelTestsDir+"testCorrlInvokeReply/msg4.txt"}; - expectedResponse = ".*xml.*jayme.*cory.*heading.*body.*cory.*testinvoke.*jayme.*"; -//"Fault Message:null\n"+ -//"Part \"newParameter2\" value: <?xml version=\"1.0\" encoding=\"UTF-8\"?><tns1:note xmlns:tns=\"urn:mycompany:/corrlcr/invokereplycorrls\" xmlns:tns1=\"http://www.w3schools.com\"; xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\";><tns1:to>jayme</tns1:to><tns1:from>cory</tns1:from><tns1:heading>heading</tns1:heading><tns1:body>body</tns1:body></tns1:note>\n"+ -//"Fault Message:null\n"+ -//"Part \"newParameter2\" value: cory\n"+ -//"Fault Message:null\n"+ -//"Part \"newParameter2\" value: testinvoke\n"+ -//"Fault Message:null\n"+ -//"Part \"newParameter2\" value: jayme"; - assertTrue(go(0, null)); - } - - public void testGraftGraftChildren() throws Exception { - bpelFile = bpelTestsDir+"testGraftGraftChildren/bpelTestGraftGraftChildren.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testGraftGraftChildren/msg1.txt"}; - expectedResponse = ".*Sombrero.*Slippers.*"; - assertTrue(go(0, null)); - } - - public void testLoopedCompensation2() throws Exception { - bpelFile = bpelTestsDir+"testLoopedCompensation2/bpelTestLoopedCompensation2.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testLoopedCompensation2/msg1.txt"}; - expectedResponse = ".*AppendVar:01234567899876543210.*"; - assertTrue(go(0, null)); - } - - public void testBuildDocWithNestedNS() throws Exception { - bpelFile = bpelTestsDir+"testBuildDocWithNestedNS/bpelTestBuildDocWithNestedNS.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testBuildDocWithNestedNS/company.txt"}; - expectedResponse = ".*<ns0:Company xmlns:ns0=\"http://www.company.org\"; xmlns:ns1=\"http://www.person.org\"; xmlns:ns2=\"http://www.product.org\";><ns0:Person><ns1:Name>John Doe</ns1:Name><ns1:SSN>123-45-6789</ns1:SSN></ns0:Person><ns0:Product><ns2:Type>Widget</ns2:Type></ns0:Product></ns0:Company>.*"; - assertTrue(go(0, null)); - } - - public void testSingleRuleInCompHandler() throws Exception { - bpelFile = bpelTestsDir+"testSingleRuleInCompHandler/bpelTestSingleRuleInCompHandler.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testSingleRuleInCompHandler/msg1.txt"}; - expectedResponse = ".*true.*"; - assertTrue(go(0, null)); - } - - public void testCatchAllNonBPError1() throws Exception { - bpelFile = bpelTestsDir+"testCatchAllNonBPError/bpelTestCatchAllNonBPError.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testCatchAllNonBPError/msg1.txt"}; - expectedResponse = ".*catchAll.*"; - assertTrue(go(0, null)); - } - - public void testCatchAllNonBPError2() throws Exception { - bpelFile = bpelTestsDir+"testCatchAllNonBPError/bpelTestCatchAllNonBPError.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testCatchAllNonBPError/msg2.txt"}; - expectedResponse = ".*catchAll.*"; - assertTrue(go(0, null)); - } - - public void testCatchAllNonBPError3() throws Exception { - bpelFile = bpelTestsDir+"testCatchAllNonBPError/bpelTestCatchAllNonBPError.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testCatchAllNonBPError/msg3.txt"}; - expectedResponse = ".*catchAll.*"; - assertTrue(go(0, null)); - } - - public void testCatchFaultInFaultHandler() throws Exception { - bpelFile = bpelTestsDir+"testCatchFaultInFaultHandler/bpelTestCatchFaultInFaultHandler.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testCatchFaultInFaultHandler/msg.txt"}; - expectedResponse = ".*>works<.*"; - assertTrue(go(0,null)); - } - - public void testCatchFaultInFaultHandler2() throws Exception { - bpelFile = bpelTestsDir+"testCatchFaultInFaultHandler2/bpelTestCatchFaultInFaultHandler2.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testCatchFaultInFaultHandler2/msg.txt"}; - expectedResponse = ".*>works<.*"; - assertTrue(go(0,null)); - } - - public void testThrowInScopeInFaultHandler() throws Exception { - bpelFile = bpelTestsDir+"testThrowInScopeInFaultHandler/bpelTestThrowInScopeInFaultHandler.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testThrowInScopeInFaultHandler/msg.txt" }; - expectedResponse = ".*>doesn&apos;t work<.*"; - assertTrue(go(0,null)); - } - - public void testThrowInScopeInFaultHandler2() throws Exception { - bpelFile = bpelTestsDir+"testThrowInScopeInFaultHandler2/bpelTestThrowInScopeInFaultHandler2.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testThrowInScopeInFaultHandler2/msg.txt" }; - expectedResponse = ".*>doesn&apos;t work<.*"; - assertTrue(go(0,null)); - } - - // this realy doesn't test the deadlock - // this test is also run in another appserver threaded test - // to test for the deadlock - public void testBPInvokeDeadlock() throws Exception { - bpelFile = bpelTestsDir+"testBPInvokeDeadlock/bpelTestBPInvokeDeadlock.jar"; - threadNumber=1; - msgFiles = new String [] {bpelTestsDir+"testBPInvokeDeadlock/deadlock1.txt", - bpelTestsDir+"testBPInvokeDeadlock/deadlock2.txt"}; - expectedResponse = - "Fault Message:null\n"+ - "Part \"newParameter2\" value: test\n"+ - "Fault Message:null\n"+ - "Part \"newParameter2\" value: test\n"; - assertTrue(go(0,null)); - } - - /* (non-Javadoc) - * @see junit.framework.TestCase#setUp() - */ - protected void setUp() throws Exception { - super.setUp(); - getSystemProps(); - } -} +/* + * Copyright 2006 The Apache Software Foundation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. +*/ +/* + * Created on Jan 26, 2004 + * + * To change the template for this generated file go to + * Window>Preferences>Java>Code Generation>Code and Comments + */ +package org.apache.ode.bpe.test; + +import java.util.Iterator; + +import org.apache.ode.bpe.cc.client.InstanceState; +import org.apache.ode.bpe.cc.data.DefinitionData; +import org.apache.ode.bpe.cc.data.InstanceData; + + +/** + * @author charper + * + * To change the template for this generated type comment go to + * Window>Preferences>Java>Code Generation>Code and Comments + */ +public class BPELTests extends BPELTester { + + + + /** + * Constructor for BPELTests. + * @param arg0 + */ + public BPELTests(String arg0) { + super(arg0); + } + + + + public void testTestRelativeSchemaImports() throws Exception { + + bpelFile = bpelTestsDir+"testRelativeSchemaImports/bpelTestRelativeSchemaImports.jar"; + threadNumber=1; + msgFiles = new String [] { + bpelTestsDir+"testRelativeSchemaImports/data1_1.txt", + bpelTestsDir+"testRelativeSchemaImports/data1_2.txt", + bpelTestsDir+"testRelativeSchemaImports/data1_3.txt", + bpelTestsDir+"testRelativeSchemaImports/data1_4.txt", + bpelTestsDir+"testRelativeSchemaImports/data1_5.txt", + bpelTestsDir+"testRelativeSchemaImports/data1_6.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: testRelativeImportsProcess complete\n"+ +"Part \"replyText\" value: Event Start TestRelativeImports.1 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> testRelativeImportsProcess complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: testRelativeImportsProcess complete\n"+ +"Part \"replyText\" value: Event Start TestRelativeImports.2 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> testRelativeImportsProcess complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: testRelativeImportsProcess complete\n"+ +"Part \"replyText\" value: Event Start TestRelativeImports.3 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> testRelativeImportsProcess complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: testRelativeImportsProcess complete\n"+ +"Part \"replyText\" value: Event Start TestRelativeImports.4 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> testRelativeImportsProcess complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: testRelativeImportsProcess complete\n"+ +"Part \"replyText\" value: Event Start TestRelativeImports.5 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> case max: set loop iterations = 10 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> 7 -> 8 -> 9 -> 10 -> 11 -> testRelativeImportsProcess complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: testRelativeImportsProcess complete\n"+ +"Part \"replyText\" value: Event Start TestRelativeImports.6 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> otherwise: set loop iterations = 0 -> test loop iterations -> testRelativeImportsProcess complete\n"; + + assertTrue(go(0, null)); + } + + + public void testTest1() throws Exception { + + bpelFile = bpelTestsDir+"test1/bpelTest1.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test1/data1_1.txt",bpelTestsDir+"test1/data1_2.txt", + bpelTestsDir+"test1/data1_3.txt",bpelTestsDir+"test1/data1_4.txt",bpelTestsDir+"test1/data1_5.txt", + bpelTestsDir+"test1/data1_6.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: test1Process complete\n"+ +"Part \"replyText\" value: Event Start Test1.1 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> test1Process complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: test1Process complete\n"+ +"Part \"replyText\" value: Event Start Test1.2 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> test1Process complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: test1Process complete\n"+ +"Part \"replyText\" value: Event Start Test1.3 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> test1Process complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: test1Process complete\n"+ +"Part \"replyText\" value: Event Start Test1.4 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> merge into root process -> test switch statement -> case min: set loop iterations = 5 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> test1Process complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: test1Process complete\n"+ +"Part \"replyText\" value: Event Start Test1.5 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> case max: set loop iterations = 10 -> test loop iterations -> 2 -> 3 -> 4 -> 5 -> 6 -> 7 -> 8 -> 9 -> 10 -> 11 -> test1Process complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: test1Process complete\n"+ +"Part \"replyText\" value: Event Start Test1.6 -> root process splits into A and B -> process [AB] completes -> process [AB] completes -> processes A and B merge on process C -> merge into root process -> test switch statement -> otherwise: set loop iterations = 0 -> test loop iterations -> test1Process complete\n"; + + assertTrue(go(0, null)); + } + + public void testTest10() throws Exception { + bpelFile = bpelTestsDir+"test10/bpelTest10.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test10/data10_1.txt",bpelTestsDir+"test10/data10_3.txt", + bpelTestsDir+"test10/data10_4.txt",bpelTestsDir+"test10/data10_2.txt"}; + expectedResponse= +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test10.1 -> block for next message -> received event on port test10_3PT -> received event on port test10_4PT -> process complete\n"; + assertTrue(go(0, null)); + } + + + public void testTest12() throws Exception { + bpelFile = bpelTestsDir+"test12/bpelTest12.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test12/data12_1.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: Start Test12\n"+ +"Part \"replyText\" value: pass\n"; + assertTrue(go(0, null)); + } + + public void testTest13() throws Exception { + bpelFile = bpelTestsDir+"test13/bpelTest13.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test13/data13_1.txt"}; + expectedResponse ="Fault Message:null\n"+ +"Part \"replyID\" value: Test13\n"+ +"Part \"replyText\" value: pass\n"; + assertTrue(go(0, null)); + } + + public void testTest14() throws Exception { + bpelFile = bpelTestsDir+"test14/bpelTest14.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test14/data14_1.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: Test14\n"+ +"Part \"replyText\" value: pass\n"; + assertTrue(go(0, null)); + } + + public void testTest15() throws Exception { + bpelFile = bpelTestsDir+"test15/bpelTest15.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test15/data15_1.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: Start Test15\n"+ +"Part \"replyText\" value: pass\n"; + assertTrue(go(0, null)); + } + + + public void testTest2() throws Exception { + bpelFile = bpelTestsDir+"test2/bpelTest2.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test2/data2_1.txt",bpelTestsDir+"test2/data2_2.txt", + bpelTestsDir+"test2/data2_3.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test2.1 -> throw testFault -> caught testFault -> process complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: caught fault with catchAll\n"+ +"Part \"replyText\" value: Event Start Test2.2 -> throw unknown fault -> caught fault with catchAll\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test2.3 -> process complete\n"; + assertTrue(go(0, null)); + } + + public void testTest3() throws Exception { + bpelFile = bpelTestsDir+"test3/bpelTest3.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test3/data3_1.txt",bpelTestsDir+"test3/data3_2.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test3.1 -> begin fault test -> throw testFault -> caught testFault -> process complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test3.2 -> begin fault test -> throw unknown fault -> process complete\n"; + assertTrue(go(0, null)); + } + + + public void testTest5() throws Exception { + bpelFile = bpelTestsDir+"test5/bpelTest5.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test5/data5_1_1.txt",bpelTestsDir+"test5/data5_1_2.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test5.1 -> loop on receive until message includes requestEnd = yes -> received message -> process complete\n"; + assertTrue(go(0, null)); + } + + public void testTest6() throws Exception { + bpelFile = bpelTestsDir+"test6/bpelTest6.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test6/data6_1.txt",bpelTestsDir+"test6/data6_2.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test6.1 -> pick branch one invoked -> process complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test6.2 -> pick branch two invoked -> process complete\n"; + assertTrue(go(0, null)); + } + + public void testTest7() throws Exception { + bpelFile = bpelTestsDir+"test7/bpelTest7.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test7/data7_1.txt",bpelTestsDir+"test7/data7_3.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test7.1 -> block for next message -> pick branch two invoked -> process complete\n"; + assertTrue(go(0, null)); + } + + + public void testTest8() throws Exception { + bpelFile = bpelTestsDir+"test8/bpelTest8.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test8/data8_1.txt",bpelTestsDir+"test8/data8_3.txt", + bpelTestsDir+"test8/data8_4.txt",bpelTestsDir+"test8/data8_2.txt",bpelTestsDir+"test8/data8_2.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test8.1 -> block for next message -> received event on port test8_3PT -> received event on port test8_4PT -> block for next message -> process complete\n"; + assertTrue(go(0, null)); + } + + public void testTest9() throws Exception { + bpelFile = bpelTestsDir+"test9/bpelTest9.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test9/data9_1.txt",bpelTestsDir+"test9/data9_2_1.txt", + bpelTestsDir+"test9/data9_2_2.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test9.1 -> loop on pick until message includes requestEnd = yes -> pick branch one invoked -> pick branch two invoked -> process complete\n"; + assertTrue(go(0, null)); + } + + public void testTest16() throws Exception { + bpelFile = bpelTestsDir+"test16/bpelTest16.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test16/data16_1.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n" + +"Part \"replyText\" value: Event Start Test16.1 -> caught uninitializedVariable -> process complete\n"; + + + assertTrue(go(0, null)); + } + + public void testTest17() throws Exception { + bpelFile = bpelTestsDir+"test17/bpelTest17.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test17/data17_1.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: process complete\n"+ +"Part \"replyText\" value: Event Start Test17.1 -> caught FaultMessage -> fault text one -> process complete\n"; + assertTrue(go(0, null)); + } + + public void testTestBPChain() throws Exception { + bpelFile = bpelTestsDir+"testBPChain/bpelTestBPChain.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testBPChain/data1_1.txt"}; + expectedResponse = "Fault Message:null.*response1.*some reply text.*"; +/*"Fault Message:null\n"+ +"Part \"responses\" value: <.xml version=\"1.0\" encoding=\"UTF-8\".>\n"+ +"<response1>response1</response1>\n"+ +"Part \"replyID\" value: a reply ID\n"+ +"Part \"replyText\" value: some reply text\n";*/ + + assertTrue(go(0, null)); + } + +/* public void testTimer1() throws Exception { + bpelFile = "testTimer1/bpelTestTimer1.jar"; + threadNumber=1; + msgFiles = new String [] {"testTimer1/timer1Data.txt","testTimer1/timer1Data.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"replyText\" value: PT3SPT7S\n"; + assertTrue(go(30000)); + } + + public void testTimer2() throws Exception { + bpelFile = "testTimer2/bpelTestTimer2.jar"; + threadNumber=1; + msgFiles = new String [] {"testTimer2/timer2Data.txt","testTimer2/timer2Data.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"replyText\" value: TESTPT7S\n"; + assertTrue(go(20000)); + } + + public void testTimer3() throws Exception { + bpelFile = "testTimer3/bpelTestTimer3.jar"; + threadNumber=1; + msgFiles = new String [] {"testTimer3/timer3Data.txt"}; + expectedResponse = +"Fault Message:null\n"; + assertTrue(go(1000)); + }*/ + + public void testTerminate() throws Exception { + bpelFile = bpelTestsDir+"testTerminate/bpelTestTerminate.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testTerminate/terminate1Data.txt"}; + expectedResponse = +"Fault Message:null\n"; + assertTrue(go(0, null)); + } + + public void testTerminateTest5() throws Exception { + bpelFile = bpelTestsDir+"test5/bpelTest5.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"test5/data5_1_1.txt"}; //,"test5/data5_1_2.txt"}; + expectedResponse = +"Fault Message:null\n";//+ +//"Fault Message:null\n"+ +//"Part \"replyID\" value: process complete\n"+ +//"Part \"replyText\" value: Event Start Test5.1 -> loop on receive until message includes requestEnd = yes -> received message -> process complete\n"; + //assertTrue( + go(0, null);//); + + Iterator it = ccs.getDefinitionData().iterator(); + while ( it.hasNext() ) { + DefinitionData dd = (DefinitionData)it.next(); + if ( dd.getName().equals("test5Process")) { + Iterator it2 = ccs.getInstancesData(dd.getID()).iterator(); + while ( it2.hasNext() ) { + InstanceData id = (InstanceData)it2.next(); + ccs.terminateInstance(id); + } + break; + } + } + + // look for the process agian + it = ccs.getDefinitionData().iterator(); + while ( it.hasNext() ) { + DefinitionData dd = (DefinitionData)it.next(); + if ( dd.getName().equals("test5Process")) { + Iterator it2 = ccs.getInstancesData(dd.getID()).iterator(); + while ( it2.hasNext() ) { + InstanceData id = (InstanceData)it2.next(); + if ( ! id.getState().toString().equals(InstanceState.FINISHED.toString()) ) { + assertTrue(false); + return; + } + } + } + } + assertTrue(true); + } + + + + public void testScopedCorrelationSets() throws Exception { + bpelFile = bpelTestsDir+"testScopedCorrelationSets/bpelTestScopedCorrelationSets.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testScopedCorrelationSets/data1.txt", + bpelTestsDir+"testScopedCorrelationSets/data2.txt",bpelTestsDir+"testScopedCorrelationSets/data3.txt"}; + expectedResponse = + "Fault Message:null\n"+ + "Fault Message:null\n"+ + "Fault Message:null\n"+ + "Part \"replyText\" value: corrl2\n"; + assertTrue(go(0, null)); + } + + public void testCatchForcedTermination() throws Exception { + bpelFile = bpelTestsDir+"testCatchForcedTerminate/bpelTestCatchForcedTerminate.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testCatchForcedTerminate/data1.txt", + bpelTestsDir+"testCatchForcedTerminate/data3.txt"}; + expectedResponse = + "Fault Message:null\n"+ + "Fault Message:null\n"+ + "Part \"replyText\" value: forcedTermination\n"; + assertTrue(go(0, null)); + } + + public void testFaultInCompensationHandler() throws Exception { + bpelFile = bpelTestsDir+"testFaultInCompensationHandler/bpelTestFaultInCompensationHandler.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testFaultInCompensationHandler/data1.txt", + bpelTestsDir+"testFaultInCompensationHandler/data3.txt"}; + expectedResponse = + "Fault Message:null\n"+ + "Fault Message:null\n"+ + "Part \"replyText\" value: msg1\n"; + assertTrue(go(0, null)); + } + + public void testFaultInFaultHandler() throws Exception { + bpelFile = bpelTestsDir+"testFaultInFaultHandler/bpelTestFaultInFaultHandler.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testFaultInFaultHandler/data1.txt"}; + expectedResponse = + "Fault Message:null\n"+ + "Part \"replyText\" value: ScopeOneTwoFaultHandler -> RootScopeFaultHandler\n"; + assertTrue(go(0, null)); + } + +/* public void testTimerOnAlarmAtRootScope() throws Exception { + bpelFile = "testTimerOnAlarmAtRootScope/bpelTestTimerOnAlarmAtRootScope.jar"; + threadNumber=1; + msgFiles = new String [] {"testTimerOnAlarmAtRootScope/timer1Data.txt","testTimerOnAlarmAtRootScope/timer1Data.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"replyText\" value: PT3SPT7S\n"; + assertTrue(go(30000)); + }*/ + + public void testOOBData() throws Exception { + bpelFile = bpelTestsDir+"testOOBData/bpelTestOOBData.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testOOBData/oOBData.txt",bpelTestsDir+"testOOBData/oOBData2.txt"}; + Object[] oobData = new Object[] {"junk",null}; + expectedResponse = + "Fault Message:null\n"+ + "Fault Message:null\n"+ + "Part \"replyText\" value: junk\n"; + assertTrue(go(0, oobData)); + } + + public void testNSDeploy() throws Exception { + bpelFile = bpelTestsDir+"testNSDeploy/bpelTestNSDeploy.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testNSDeploy/nSDeploy.txt"}; + expectedResponse = + "Fault Message:null\n"+ + "Part \"replyText\" value: PT7S\n"; + assertTrue(go(0, null)); + } + + public void testLocalInvoke() throws Exception { + bpelFile = bpelTestsDir+"testLocalInvoke/bpelTestLocalInvoke.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testLocalInvoke/localInvoke1.txt"}; + expectedResponse = + "Fault Message:null\n"+ + "Part \"replyText\" value: test\n"; + assertTrue(go(0, null)); + } + + public void testLinkInSwitch() throws Exception { + bpelFile = bpelTestsDir+"testLinkInSwitch/bpelTestLinkInSwitch.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testLinkInSwitch/dataLIS_1.txt",bpelTestsDir+"testLinkInSwitch/dataLIS_2.txt", + bpelTestsDir+"testLinkInSwitch/dataLIS_3.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Part \"replyID\" value: testLinkInSwitch complete\n"+ +"Part \"replyText\" value: Start TestLIS.1 -> case1 -> test switch link -> switch-case1 -> known-message -> testLinkInSwitch complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: testLinkInSwitch complete\n"+ +"Part \"replyText\" value: Start TestLIS.2 -> case2 -> test switch link -> switch-case2 -> known-message -> testLinkInSwitch complete\n"+ +"Fault Message:null\n"+ +"Part \"replyID\" value: testLinkInSwitch complete\n"+ +"Part \"replyText\" value: Start TestLIS.3 -> otherwise -> test switch link -> switch-otherwise -> unknown-message -> testLinkInSwitch complete\n"; + assertTrue(go(0, null)); + } + + public void testQts377278() throws Exception { + bpelFile = bpelTestsDir+"testQts377278/bpelTestQts377278.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testQts377278/data.txt"}; + expectedResponse = + "Fault Message:null\n"; + assertTrue(go(0, null)); + } + + public void testPartnerLinkAssign() throws Exception { + bpelFile = bpelTestsDir+"testPartnerLinkAssign/bpelTestPartnerLinkAssign.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testPartnerLinkAssign/data.txt"}; + expectedResponse = + "Fault Message:null\n"+ + "Part \"replyText\" value: partnerLinkDataInpartnerLinkDataOut\n"; + assertTrue(go(0, null)); + } + + public void testNestedSplits() throws Exception { + bpelFile = bpelTestsDir+"testNestedSplits/bpelTestNestedSplits.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testNestedSplits/links.props"}; + expectedResponse = + "Fault Message:null\n"+ + "Part \"InParam\" value: franklin\n"; + assertTrue(go(0, null)); + } + + public void testReplyWithFault() throws Exception { + bpelFile = bpelTestsDir+"testReplyWithFault/bpelTestReplyWithFault.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testReplyWithFault/dataReplyWithFault.txt"}; + expectedResponse = +"Fault Message:Fault Actor:null Fault Code:null Fault String:testFault\n"+ +"FaultPart \"faultID\" value: fault text one\n"+ +"FaultPart \"faultText\" value: Event Start Test ReplyWithFault -> caught FaultMessage -> fault text one\n\n"; + assertTrue(go(0, null)); + } + + public void testCorrlCmplx() throws Exception { + bpelFile = bpelTestsDir+"testCorrlCmplx/bpelTestCorrlCmplx.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testCorrlCmplx/msg1.txt", + bpelTestsDir+"testCorrlCmplx/msg2.txt", + bpelTestsDir+"testCorrlCmplx/msg3.txt"}; + expectedResponse = +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Fault Message:null\n"+ +"Part \"newParameter2\" value: cory\n"; + assertTrue(go(0, null)); + } + + public void testCorrlInvokeReply() throws Exception { + bpelFile = bpelTestsDir+"testCorrlInvokeReply/bpelTestCorrlInvokeReply.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testCorrlInvokeReply/msg1.txt", + bpelTestsDir+"testCorrlInvokeReply/msg2.txt", + bpelTestsDir+"testCorrlInvokeReply/msg3.txt", + bpelTestsDir+"testCorrlInvokeReply/msg4.txt"}; + expectedResponse = ".*xml.*jayme.*cory.*heading.*body.*cory.*testinvoke.*jayme.*"; +//"Fault Message:null\n"+ +//"Part \"newParameter2\" value: <?xml version=\"1.0\" encoding=\"UTF-8\"?><tns1:note xmlns:tns=\"urn:mycompany:/corrlcr/invokereplycorrls\" xmlns:tns1=\"http://www.w3schools.com\"; xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\";><tns1:to>jayme</tns1:to><tns1:from>cory</tns1:from><tns1:heading>heading</tns1:heading><tns1:body>body</tns1:body></tns1:note>\n"+ +//"Fault Message:null\n"+ +//"Part \"newParameter2\" value: cory\n"+ +//"Fault Message:null\n"+ +//"Part \"newParameter2\" value: testinvoke\n"+ +//"Fault Message:null\n"+ +//"Part \"newParameter2\" value: jayme"; + assertTrue(go(0, null)); + } + + public void testGraftGraftChildren() throws Exception { + bpelFile = bpelTestsDir+"testGraftGraftChildren/bpelTestGraftGraftChildren.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testGraftGraftChildren/msg1.txt"}; + expectedResponse = ".*Sombrero.*Slippers.*"; + assertTrue(go(0, null)); + } + + public void testLoopedCompensation2() throws Exception { + bpelFile = bpelTestsDir+"testLoopedCompensation2/bpelTestLoopedCompensation2.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testLoopedCompensation2/msg1.txt"}; + expectedResponse = ".*AppendVar:01234567899876543210.*"; + assertTrue(go(0, null)); + } + + public void testBuildDocWithNestedNS() throws Exception { + bpelFile = bpelTestsDir+"testBuildDocWithNestedNS/bpelTestBuildDocWithNestedNS.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testBuildDocWithNestedNS/company.txt"}; + expectedResponse = ".*<ns0:Company xmlns:ns0=\"http://www.company.org\"; xmlns:ns1=\"http://www.person.org\"; xmlns:ns2=\"http://www.product.org\";><ns0:Person><ns1:Name>John Doe</ns1:Name><ns1:SSN>123-45-6789</ns1:SSN></ns0:Person><ns0:Product><ns2:Type>Widget</ns2:Type></ns0:Product></ns0:Company>.*"; + assertTrue(go(0, null)); + } + + public void testSingleRuleInCompHandler() throws Exception { + bpelFile = bpelTestsDir+"testSingleRuleInCompHandler/bpelTestSingleRuleInCompHandler.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testSingleRuleInCompHandler/msg1.txt"}; + expectedResponse = ".*true.*"; + assertTrue(go(0, null)); + } + + public void testCatchAllNonBPError1() throws Exception { + bpelFile = bpelTestsDir+"testCatchAllNonBPError/bpelTestCatchAllNonBPError.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testCatchAllNonBPError/msg1.txt"}; + expectedResponse = ".*catchAll.*"; + assertTrue(go(0, null)); + } + + public void testCatchAllNonBPError2() throws Exception { + bpelFile = bpelTestsDir+"testCatchAllNonBPError/bpelTestCatchAllNonBPError.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testCatchAllNonBPError/msg2.txt"}; + expectedResponse = ".*catchAll.*"; + assertTrue(go(0, null)); + } + + public void testCatchAllNonBPError3() throws Exception { + bpelFile = bpelTestsDir+"testCatchAllNonBPError/bpelTestCatchAllNonBPError.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testCatchAllNonBPError/msg3.txt"}; + expectedResponse = ".*catchAll.*"; + assertTrue(go(0, null)); + } + + public void testCatchFaultInFaultHandler() throws Exception { + bpelFile = bpelTestsDir+"testCatchFaultInFaultHandler/bpelTestCatchFaultInFaultHandler.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testCatchFaultInFaultHandler/msg.txt"}; + expectedResponse = ".*>works<.*"; + assertTrue(go(0,null)); + } + + public void testCatchFaultInFaultHandler2() throws Exception { + bpelFile = bpelTestsDir+"testCatchFaultInFaultHandler2/bpelTestCatchFaultInFaultHandler2.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testCatchFaultInFaultHandler2/msg.txt"}; + expectedResponse = ".*>works<.*"; + assertTrue(go(0,null)); + } + + public void testThrowInScopeInFaultHandler() throws Exception { + bpelFile = bpelTestsDir+"testThrowInScopeInFaultHandler/bpelTestThrowInScopeInFaultHandler.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testThrowInScopeInFaultHandler/msg.txt" }; + expectedResponse = ".*>doesn&apos;t work<.*"; + assertTrue(go(0,null)); + } + + public void testThrowInScopeInFaultHandler2() throws Exception { + bpelFile = bpelTestsDir+"testThrowInScopeInFaultHandler2/bpelTestThrowInScopeInFaultHandler2.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testThrowInScopeInFaultHandler2/msg.txt" }; + expectedResponse = ".*>doesn&apos;t work<.*"; + assertTrue(go(0,null)); + } + + // this realy doesn't test the deadlock + // this test is also run in another appserver threaded test + // to test for the deadlock + public void testBPInvokeDeadlock() throws Exception { + bpelFile = bpelTestsDir+"testBPInvokeDeadlock/bpelTestBPInvokeDeadlock.jar"; + threadNumber=1; + msgFiles = new String [] {bpelTestsDir+"testBPInvokeDeadlock/deadlock1.txt", + bpelTestsDir+"testBPInvokeDeadlock/deadlock2.txt"}; + expectedResponse = + "Fault Message:null\n"+ + "Part \"newParameter2\" value: test\n"+ + "Fault Message:null\n"+ + "Part \"newParameter2\" value: test\n"; + assertTrue(go(0,null)); + } + + /* (non-Javadoc) + * @see junit.framework.TestCase#setUp() + */ + protected void setUp() throws Exception { + super.setUp(); + getSystemProps(); + } +}
