Hi everybody, I am using ode 1.2. I have a problem with Asynchronous. I see that the process is stopped while using activity onAlarm on the activity Pick, if not it infinitely runs. In addition, I see that message Correlation is set. Could you help me to understand how I can solve this problem.
Thanks,
Kinh
DEBUG - GeronimoLog.debug(66) | >>
handleWorkEvent(jobData={ckey=35~http://www.t
si.enst.fr/~~elloumi/MediasDB/trailers/kill_bill_small.mp4,
correlatorId=36.say,
inmem=false, iid=201, type=MATCHER})
DEBUG - GeronimoLog.debug(66) | BpelRuntimeContextImpl created for
instance 201.
INDEXED STATE={{OScope 'Scope' id=56}::14=[SCOPE(...)],
OSequence#38-main::1=[A
CTIVITYGUARD(...)], OPickReceive#67-Pick::20=[PICK(...)],
OSequence#57-Sequence:
:15=[ACTIVITYGUARD(...)],
OSequence#38-main::2=[SEQUENCE(self=(OSequence#38-main
,TerminationChannel#3,ParentScopeChannel#5),
linkframe=org.apache.ode.bpel.runti
[EMAIL PROTECTED], remaining=[{OScope 'Scope' id=56}, {OScope
'callbackClient
' id=90}])], {OScope '__PROCESS_SCOPE:Test' id=20}::0=[ACTIVE(...)],
{OScope '__
PROCESS_SCOPE:Test' id=20}::0=[SCOPE(...)],
OPickReceive#67-Pick::19=[ACTIVITYGU
ARD(...)], {OScope 'Scope' id=56}::13=[ACTIVITYGUARD(...)],
OSequence#57-Sequenc
e::16=[SEQUENCE(self=(OSequence#57-Sequence,TerminationChannel#25,ParentScopeCha
nnel#27), [EMAIL PROTECTED],
remaining=[OP
ickReceive#67-Pick])], {OScope 'Scope' id=56}::14=[ACTIVE(...)]}
DEBUG - GeronimoLog.debug(66) | Matcher event for iid 201
DEBUG - GeronimoLog.debug(66) | MatcherEvent handling:
correlatorId=36.say, ckey
={CorrelationKey setId=35,
values=[http://www.tsi.enst.fr/~elloumi/MediasDB/trai
lers/kill_bill_small.mp4]}
DEBUG - GeronimoLog.debug(66) | MatcherEvent handling: nothing to do, no
matchin
g message in DB
DEBUG - GeronimoLog.debug(66) | Thread[ODEServer-1,5,main]: unlock(iid=201)
Here is my BPEL:
<?xml version="1.0" encoding="UTF-8"?>
<bpws:process exitOnStandardFault="yes" name="Test"
suppressJoinFailure="yes" targetNamespace="http://www.tsi.enst.fr";
xmlns:bpws="http://docs.oasis-open.org/wsbpel/2.0/process/executable";
xmlns:ns="http://www.tsi.enst.frArtifacts"; xmlns:ns0="http://paam";
xmlns:ns1="UGGH" xmlns:tns="http://www.tsi.enst.fr";>
<bpws:import importType="http://schemas.xmlsoap.org/wsdl/";
location="Test.wsdl" namespace="http://www.tsi.enst.fr"/>
<bpws:import importType="http://schemas.xmlsoap.org/wsdl/";
location="TestArtifacts.wsdl"
namespace="http://www.tsi.enst.frArtifacts"/>
<bpws:import importType="http://schemas.xmlsoap.org/wsdl/";
location="Video.wsdl" namespace="http://paam"/>
<bpws:import importType="http://schemas.xmlsoap.org/wsdl/";
location="TestArtifacts.wsdl" namespace="UGGH"/>
<bpws:partnerLinks>
<bpws:partnerLink initializePartnerRole="yes"
myRole="TestProvider" name="client"
partnerLinkType="tns:Test" partnerRole="TestRequester"/>
<bpws:partnerLink name="linkVideo"
partnerLinkType="ns1:partnerLinkVideo" partnerRole="videoRole"/>
</bpws:partnerLinks>
<bpws:variables>
<bpws:variable messageType="tns:TestRequestMessage" name="input"/>
<bpws:variable messageType="tns:TestResponseMessage" name="output"/>
<bpws:variable messageType="ns0:changeScaleResponse"
name="linkVideoResponse"/>
<bpws:variable messageType="ns0:changeScaleRequest"
name="linkVideoRequest"/>
<bpws:variable messageType="tns:sayRequestMessage"
name="clientResponse"/>
</bpws:variables>
<bpws:correlationSets>
<bpws:correlationSet name="CS" properties="ns1:stUrl"/>
</bpws:correlationSets>
<bpws:sequence name="main">
<bpws:receive createInstance="yes" name="receiveInput"
operation="initiate" partnerLink="client"
portType="tns:Test" variable="input"/>
<bpws:assign name="Assign" validate="no">
<bpws:copy>
<bpws:from>
<bpws:literal>
<tns:TestResponseMessage
xmlns:tns="http://www.tsi.enst.fr";>
<tns:result/>
</tns:TestResponseMessage>
</bpws:literal>
</bpws:from>
<bpws:to part="payload" variable="output"/>
</bpws:copy>
<bpws:copy>
<bpws:from>
<bpws:literal>
<changeScaleRequest>
<stUrl>http://www.tsi.enst.fr/~elloumi/MediasDB/trailers/kill_bill_small.mp4</stUrl>
<width>200</width>
<height>200</height>
</changeScaleRequest>
</bpws:literal>
</bpws:from>
<bpws:to part="parameters" variable="linkVideoRequest"/>
</bpws:copy>
</bpws:assign>
<bpws:invoke inputVariable="linkVideoRequest" name="Invoke"
operation="changeScale" outputVariable="linkVideoResponse"
partnerLink="linkVideo" portType="ns0:Video">
<bpws:correlations>
<bpws:correlation initiate="yes" pattern="out" set="CS"/>
</bpws:correlations>
</bpws:invoke>
<bpws:scope name="Scope">
<bpws:sequence name="Sequence">
<bpws:assign name="Assign2" validate="no">
<bpws:copy>
<bpws:from>
<bpws:literal>
<sayRequestMessage>
<stUrl/>
</sayRequestMessage>
</bpws:literal>
</bpws:from>
<bpws:to part="payload" variable="clientResponse"/>
</bpws:copy>
<bpws:copy>
<bpws:from><![CDATA[$linkVideoRequest.parameters/stUrl]]></bpws:from>
<bpws:to><![CDATA[$clientResponse.payload/stUrl]]></bpws:to>
</bpws:copy>
</bpws:assign>
<bpws:pick createInstance="no" name="Pick">
<bpws:onMessage operation="say" partnerLink="client"
portType="tns:Test" variable="clientResponse">
<bpws:correlations>
<bpws:correlation initiate="no" set="CS"/>
</bpws:correlations>
<bpws:sequence name="Sequence1">
<bpws:assign name="Assign1" validate="no">
<bpws:copy>
<bpws:from><![CDATA[$linkVideoResponse.parameters/ns0:changeScaleReturn]]></bpws:from>
<bpws:to><![CDATA[$output.payload/tns:result]]></bpws:to>
</bpws:copy>
<bpws:copy>
<bpws:from><![CDATA[$output.payload/tns:result]]></bpws:from>
<bpws:to part="payload"
variable="output">
<bpws:query
queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[/tns:result]]></bpws:query>
</bpws:to>
</bpws:copy>
</bpws:assign>
</bpws:sequence>
</bpws:onMessage>
</bpws:pick>
</bpws:sequence>
</bpws:scope>
<bpws:invoke inputVariable="output" name="callbackClient"
operation="onResult" partnerLink="client"
portType="tns:TestCallback"/>
</bpws:sequence>
</bpws:process>
--
NGUYEN Cong Kinh
Test.wsdl
Description: XML document
TestArtifacts.wsdl
Description: XML document
Video.wsdl
Description: XML document
