You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ode.apache.org by Lei Wang <ma...@gmail.com> on 2014/08/04 19:47:45 UTC
how to get the "supressJoinFailure" attribute from compiled .cbp file
Hi,
I want some help on how to get the "supressJoinFailure" attribute value
from a compiled .cbp file.
What I have done:
//Compile a bpel process into .cbp
BpelC bpelC = BpelC.newBpelCompiler();
bpelC.compile(bpelFile, 2);
//read the compiled file as a OProcess Object
Serializer ofh = new Serializer(new FileInputStream(cbpPath));
OProcess compiledProcess = ofh.readOProcess();
The motivation is use ODE library to get a JAVA Object representation of
BPEL process.
Then I want to do some static analysis based on the JAVA representation.
The question is, how can I get the process attribute of
"supressJoinFailure" attribute of JAVA OProcess class.
Best Regards
Lei Wang
Re: how to get the "supressJoinFailure" attribute from compiled .cbp file
Posted by Lei Wang <ma...@gmail.com>.
Hi,
I tried the "compiledProcess.processScope.suppressJoinFailure"
I used the following BPEL file as a test, whatever the
"suppressJoinFailure" attribute is in the BPEL,
the "compiledProcess.processScope.suppressJoinFailure" JAVA OProcess Object
always returns "false".
The ODE library I use is the "master" branch in the git repository.
The BPEL source:
<bpel:process name="whileResponder"
targetNamespace="http://www.utwente.nl/ewi/db/whileResponder"
suppressJoinFailure="yes" xmlns:tns="
http://www.utwente.nl/ewi/db/whileResponder"
xmlns:bpel="http://docs.oasis-open.org/wsbpel/2.0/process/executable">
<bpel:import location="whileResponderArtifacts.wsdl"
namespace="http://www.utwente.nl/ewi/db/whileResponder" importType="
http://schemas.xmlsoap.org/wsdl/" />
<bpel:correlationSets>
<bpel:correlationSet name="CS" properties="tns:SN" />
</bpel:correlationSets>
<bpel:partnerLinks>
<bpel:partnerLink name="whileResponder"
partnerLinkType="tns:whileResponder" myRole="whileResponder" />
</bpel:partnerLinks>
<bpel:variables>
<bpel:variable name="M1" messageType="tns:invoke1M1Message" />
<bpel:variable name="M2" messageType="tns:invoke1M2Message" />
<bpel:variable name="M3" messageType="tns:invoke2M3Message" />
<bpel:variable name="M4" messageType="tns:invoke2M4Message" />
<bpel:variable name="M5" messageType="tns:invoke3M5Message" />
</bpel:variables>
<bpel:sequence name="main">
<bpel:pick createInstance="yes">
<bpel:onMessage name="initReceive1" variable="M1"
partnerLink="whileResponder" operation="invoke1">
<bpel:correlations>
<bpel:correlation set="CS" initiate="yes" />
</bpel:correlations>
<bpel:sequence>
<bpel:assign>
<bpel:copy>
<bpel:from>
<bpel:literal>
<tns:invoke1M2 xmlns:tns="
http://www.utwente.nl/ewi/db/whileResponder"
xmlns:xsi="
http://www.w3.org/2001/XMLSchema-instance">
<tns:output>tns:output</tns:output>
<tns:SN>tns:SN</tns:SN>
</tns:invoke1M2>
</bpel:literal>
</bpel:from>
<bpel:to variable="M2" part="payload" />
</bpel:copy>
<bpel:copy>
<bpel:from>$M1.payload/tns:SN</bpel:from>
<bpel:to>$M2.payload/tns:SN</bpel:to>
</bpel:copy>
<bpel:copy>
<bpel:from>$M1.payload/tns:input</bpel:from>
<bpel:to>$M2.payload/tns:output</bpel:to>
</bpel:copy>
</bpel:assign>
<bpel:reply name="initReply1"
partnerLink="whileResponder"
operation="invoke1" variable="M2" />
<bpel:receive name="initReceive2"
partnerLink="whileResponder"
operation="invoke2" variable="M3">
<bpel:correlations>
<bpel:correlation set="CS" initiatie="no" />
</bpel:correlations>
</bpel:receive>
<bpel:assign>
<bpel:copy>
<bpel:from>
<bpel:literal>
<tns:invoke2M4 xmlns:tns="
http://www.utwente.nl/ewi/db/whileResponder"
xmlns:xsi="
http://www.w3.org/2001/XMLSchema-instance">
<tns:output>tns:output</tns:output>
<tns:SN>tns:SN</tns:SN>
</tns:invoke2M4>
</bpel:literal>
</bpel:from>
<bpel:to variable="M4" part="payload" />
</bpel:copy>
<bpel:copy>
<bpel:from>$M3.payload/tns:input</bpel:from>
<bpel:to>$M4.payload/tns:output</bpel:to>
</bpel:copy>
<bpel:copy>
<bpel:from>$M3.payload/tns:SN</bpel:from>
<bpel:to>$M4.payload/tns:SN</bpel:to>
</bpel:copy>
</bpel:assign>
<bpel:reply name="initReply2" operation="invoke2"
variable="M4" partnerLink="whileResponder" />
</bpel:sequence>
</bpel:onMessage>
<bpel:onMessage partnerLink="whileResponder" variable="M5"
operation="invoke3" name="initReceive3">
<bpel:correlations>
<bpel:correlation set="CS" initiate="join" />
</bpel:correlations>
<bpel:exit />
</bpel:onMessage>
</bpel:pick>
<bpel:while>
<bpel:condition>1</bpel:condition>
<bpel:pick>
<bpel:onMessage name="receive1" variable="M1"
partnerLink="whileResponder" operation="invoke1">
<bpel:correlations>
<bpel:correlation set="CS" initiate="no" />
</bpel:correlations>
<bpel:sequence>
<bpel:assign>
<bpel:copy>
<bpel:from>$M1.payload/tns:SN</bpel:from>
<bpel:to>$M2.payload/tns:SN</bpel:to>
</bpel:copy>
<bpel:copy>
<bpel:from>$M1.payload/tns:input</bpel:from>
<bpel:to>$M2.payload/tns:output</bpel:to>
</bpel:copy>
</bpel:assign>
<bpel:reply name="reply1"
partnerLink="whileResponder"
operation="invoke1" variable="M2" />
<bpel:receive name="receive2"
partnerLink="whileResponder"
operation="invoke2" variable="M3">
<bpel:correlations>
<bpel:correlation set="CS" initiatie="no" />
</bpel:correlations>
</bpel:receive>
<bpel:assign>
<bpel:copy>
<bpel:from>$M3.payload/tns:input</bpel:from>
<bpel:to>$M4.payload/tns:output</bpel:to>
</bpel:copy>
<bpel:copy>
<bpel:from>$M3.payload/tns:SN</bpel:from>
<bpel:to>$M4.payload/tns:SN</bpel:to>
</bpel:copy>
</bpel:assign>
<bpel:reply name="reply2" operation="invoke2"
variable="M4"
partnerLink="whileResponder" />
</bpel:sequence>
</bpel:onMessage>
<bpel:onMessage partnerLink="whileResponder"
variable="M5" operation="invoke3" name="receive3">
<bpel:correlations>
<bpel:correlation set="CS" initiate="join" />
</bpel:correlations>
<bpel:exit />
</bpel:onMessage>
</bpel:pick>
</bpel:while>
</bpel:sequence>
</bpel:process>
The imported WSDL file (whileResponderArtifacts.wsdl):
<?xml version="1.0"?>
<definitions name="whileResponder"
targetNamespace="http://www.utwente.nl/ewi/db/whileResponder"
xmlns:vprop="http://docs.oasis-open.org/wsbpel/2.0/varprop" xmlns:xsd="
http://www.w3.org/2001/XMLSchema"
xmlns:tns="http://www.utwente.nl/ewi/db/whileResponder" xmlns:plnk="
http://docs.oasis-open.org/wsbpel/2.0/plnktype"
xmlns="http://schemas.xmlsoap.org/wsdl/" xmlns:soap="
http://schemas.xmlsoap.org/wsdl/soap/">
<types>
<schema attributeFormDefault="unqualified"
elementFormDefault="qualified"
targetNamespace="http://www.utwente.nl/ewi/db/whileResponder"
xmlns="http://www.w3.org/2001/XMLSchema">
<element name="invoke1M1">
<complexType>
<sequence>
<element name="input" type="string" />
<element name="SN" type="string" />
</sequence>
</complexType>
</element>
<element name="invoke1M2">
<complexType>
<sequence>
<element name="output" type="string" />
<element name="SN" type="string" />
</sequence>
</complexType>
</element>
<element name="invoke2M3">
<complexType>
<sequence>
<element name="input" type="string" />
<element name="SN" type="string" />
</sequence>
</complexType>
</element>
<element name="invoke2M4">
<complexType>
<sequence>
<element name="output" type="string" />
<element name="SN" type="string" />
</sequence>
</complexType>
</element>
<element name="invoke3M5">
<complexType>
<sequence>
<element name="input" type="string" />
<element name="SN" type="string" />
</sequence>
</complexType>
</element>
</schema>
</types>
<message name="invoke1M1Message">
<part name="payload" element="tns:invoke1M1" />
</message>
<message name="invoke1M2Message">
<part name="payload" element="tns:invoke1M2" />
</message>
<message name="invoke2M3Message">
<part name="payload" element="tns:invoke2M3" />
</message>
<message name="invoke2M4Message">
<part name="payload" element="tns:invoke2M4" />
</message>
<message name="invoke3M5Message">
<part name="payload" element="tns:invoke3M5" />
</message>
<portType name="whileResponder">
<operation name="invoke1">
<input message="tns:invoke1M1Message" />
<output message="tns:invoke1M2Message" />
</operation>
<operation name="invoke2">
<input message="tns:invoke2M3Message" />
<output message="tns:invoke2M4Message" />
</operation>
<operation name="invoke3">
<input message="tns:invoke3M5Message" />
</operation>
</portType>
<plnk:partnerLinkType name="whileResponder">
<plnk:role name="whileResponder" portType="tns:whileResponder" />
</plnk:partnerLinkType>
<vprop:property name="SN" type="xsd:string" />
<vprop:propertyAlias propertyName="tns:SN"
messageType="tns:invoke1M1Message" part="payload">
<vprop:query>tns:SN</vprop:query>
</vprop:propertyAlias>
<vprop:propertyAlias propertyName="tns:SN"
messageType="tns:invoke2M3Message" part="payload">
<vprop:query>tns:SN</vprop:query>
</vprop:propertyAlias>
<vprop:propertyAlias propertyName="tns:SN"
messageType="tns:invoke3M5Message" part="payload">
<vprop:query>tns:SN</vprop:query>
</vprop:propertyAlias>
<binding name="whileResponderBinding" type="tns:whileResponder">
<soap:binding style="document"
transport="http://schemas.xmlsoap.org/soap/http" />
<operation name="invoke1">
<soap:operation
soapAction="
http://www.utwente.nl/ewi/db/whileResponder/invoke1" />
<input>
<soap:body use="literal" />
</input>
<output>
<soap:body use="literal" />
</output>
</operation>
<operation name="invoke2">
<soap:operation
soapAction="
http://www.utwente.nl/ewi/db/whileResponder/invoke2" />
<input>
<soap:body use="literal" />
</input>
<output>
<soap:body use="literal" />
</output>
</operation>
<operation name="invoke3">
<soap:operation
soapAction="
http://www.utwente.nl/ewi/db/whileResponder/invoke3" />
<input>
<soap:body use="literal" />
</input>
</operation>
</binding>
<service name="whileResponderService">
<port name="whileResponderPort" binding="tns:whileResponderBinding">
<soap:address location="
http://localhost:8080/ode/processes/whileResponder" />
</port>
</service>
</definitions>
On Mon, Aug 4, 2014 at 7:59 PM, Tammo van Lessen <tv...@gmail.com>
wrote:
> Hi,
>
> 'compiledProcess.processScope.suppressJoinFailure' should do the job.
>
> Please bear in mind that the compiler does some (minor) optimizations. The
> fault handling of invokes is for instance implemented by wrapping the
> invoke with an implicit scope activity. The receive is replaced by a
> pick-activity with exactly one onMessage element and other of the like.
>
> HTH,
> Tammo
>
>
> On Mon, Aug 4, 2014 at 7:47 PM, Lei Wang <ma...@gmail.com> wrote:
>
> > Hi,
> >
> >
> > I want some help on how to get the "supressJoinFailure" attribute value
> > from a compiled .cbp file.
> > What I have done:
> >
> > //Compile a bpel process into .cbp
> > BpelC bpelC = BpelC.newBpelCompiler();
> > bpelC.compile(bpelFile, 2);
> > //read the compiled file as a OProcess Object
> > Serializer ofh = new Serializer(new FileInputStream(cbpPath));
> > OProcess compiledProcess = ofh.readOProcess();
> >
> >
> > The motivation is use ODE library to get a JAVA Object representation of
> > BPEL process.
> > Then I want to do some static analysis based on the JAVA representation.
> > The question is, how can I get the process attribute of
> > "supressJoinFailure" attribute of JAVA OProcess class.
> >
> >
> >
> > Best Regards
> >
> >
> > Lei Wang
> >
>
>
>
> --
> Tammo van Lessen - http://www.taval.de
>
Re: how to get the "supressJoinFailure" attribute from compiled .cbp file
Posted by Tammo van Lessen <tv...@gmail.com>.
Hi,
'compiledProcess.processScope.suppressJoinFailure' should do the job.
Please bear in mind that the compiler does some (minor) optimizations. The
fault handling of invokes is for instance implemented by wrapping the
invoke with an implicit scope activity. The receive is replaced by a
pick-activity with exactly one onMessage element and other of the like.
HTH,
Tammo
On Mon, Aug 4, 2014 at 7:47 PM, Lei Wang <ma...@gmail.com> wrote:
> Hi,
>
>
> I want some help on how to get the "supressJoinFailure" attribute value
> from a compiled .cbp file.
> What I have done:
>
> //Compile a bpel process into .cbp
> BpelC bpelC = BpelC.newBpelCompiler();
> bpelC.compile(bpelFile, 2);
> //read the compiled file as a OProcess Object
> Serializer ofh = new Serializer(new FileInputStream(cbpPath));
> OProcess compiledProcess = ofh.readOProcess();
>
>
> The motivation is use ODE library to get a JAVA Object representation of
> BPEL process.
> Then I want to do some static analysis based on the JAVA representation.
> The question is, how can I get the process attribute of
> "supressJoinFailure" attribute of JAVA OProcess class.
>
>
>
> Best Regards
>
>
> Lei Wang
>
--
Tammo van Lessen - http://www.taval.de