blob: 360df0b2c5596e627f6e837bd778a9162316d68a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you 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.
*/
package org.apache.tuscany.sca.implementation.bpel.ode;
import java.io.File;
import java.io.StringReader;
import java.net.URL;
import java.util.concurrent.Future;
import javax.transaction.TransactionManager;
import javax.xml.namespace.QName;
import javax.xml.stream.XMLInputFactory;
import javax.xml.stream.XMLStreamReader;
import junit.framework.TestCase;
import org.apache.ode.bpel.iapi.Message;
import org.apache.ode.bpel.iapi.MyRoleMessageExchange;
import org.apache.ode.bpel.iapi.MessageExchange.Status;
import org.apache.ode.utils.DOMUtils;
import org.apache.ode.utils.GUID;
import org.apache.tuscany.sca.assembly.Composite;
import org.apache.tuscany.sca.contribution.processor.DefaultStAXArtifactProcessorExtensionPoint;
import org.apache.tuscany.sca.contribution.processor.ExtensibleStAXArtifactProcessor;
import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessorExtensionPoint;
import org.apache.tuscany.sca.core.DefaultExtensionPointRegistry;
import org.apache.tuscany.sca.implementation.bpel.ode.EmbeddedODEServer;
import org.apache.tuscany.sca.implementation.bpel.ode.GeronimoTxFactory;
import org.apache.tuscany.sca.implementation.bpel.ode.ODEDeployment;
import org.w3c.dom.Element;
/**
* Test to Deploy and Invoke a HelloWorld BPEL process using EmbeddedODEServer
*
* Major changes introduced to this testcase on 27/05/2008 associated with changes in the
* implementation of EmbeddedODEServer which remove the need for the ODE deploy.xml file -
* instead a Tuscany BPELImplementation object is passed to the EmbeddedODEServer and this is
* introspected to get all the necessary information about the BPEL process
*
* @version $Rev$ $Date$
*/
public class EmbeddedODEServerTestCase extends TestCase {
private EmbeddedODEServer odeServer;
private TransactionManager txMgr;
@Override
protected void setUp() throws Exception {
// Set up the ODE BPEL server...
GeronimoTxFactory txFactory = new GeronimoTxFactory();
txMgr = txFactory.getTransactionManager();
this.odeServer = new EmbeddedODEServer(txMgr);
odeServer.init();
} // end setUp
@Override
protected void tearDown() throws Exception {
odeServer.stop();
}
public void testProcessInvocation() throws Exception {
if (!odeServer.isInitialized()) {
fail("Server did not start !");
}
// TODO - write effective testcase - made problematic by the need to supply a resolved
// BPELImplementation
/*
URL deployURL = getClass().getClassLoader().getResource("helloworld/deploy.xml");
File deploymentDir = new File(deployURL.toURI().getPath()).getParentFile();
System.out.println("Deploying : " + deploymentDir.toString());
System.out.println(deploymentDir);
if (odeServer.isInitialized()) {
try {
txMgr.begin();
odeServer.deploy(new ODEDeployment(deploymentDir), implementation);
txMgr.commit();
} catch (Exception e) {
e.printStackTrace();
txMgr.rollback();
}
// transaction one
MyRoleMessageExchange mex = null;
Future onhold = null;
try {
// invoke the process
txMgr.begin();
mex = odeServer.getBpelServer().getEngine().createMessageExchange(new GUID().toString(),
new QName("http://tuscany.apache.org/implementation/bpel/example/helloworld.wsdl", "HelloService"), "hello");
Message request = mex.createMessage(new QName("", ""));
request.setMessage(DOMUtils.stringToDOM("<message><TestPart><hello xmlns=\"http://tuscany.apache.org/implementation/bpel/example/helloworld.wsdl\">Hello</hello></TestPart></message>"));
onhold = mex.invoke(request);
txMgr.commit();
} catch (Exception e) {
e.printStackTrace();
txMgr.rollback();
}
// - end of transaction one
// Waiting until the reply is ready in case the engine needs to continue in a different thread
if (onhold != null)
onhold.get();
// transaction two
try {
txMgr.begin();
// Reloading the mex in the current transaction, otherwise we can't be sure we have
// the "freshest" one.
mex = (MyRoleMessageExchange) odeServer.getBpelServer().getEngine().getMessageExchange(mex.getMessageExchangeId());
Status status = mex.getStatus();
System.out.println("Status: " + status.name());
Element response = mex.getResponse().getMessage();
System.out.println("Response: " + DOMUtils.domToString(response));
txMgr.commit();
// end of transaction two
} catch (Exception e) {
e.printStackTrace();
txMgr.rollback();
} // end try
} // end if
*/
} // end testProcessInvocation
}
|
