Added: ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/OnEventCorrelationB111.bpel URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/OnEventCorrelationB111.bpel?rev=811583&view=auto ============================================================================== --- ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/OnEventCorrelationB111.bpel (added) +++ ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/OnEventCorrelationB111.bpel Sat Sep 5 03:34:28 2009 @@ -0,0 +1,111 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + ~ 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. + --> +<bpws:process xmlns:bpws="http://docs.oasis-open.org/wsbpel/2.0/process/executable"; xmlns:xsd="http://www.w3.org/2001/XMLSchema"; xmlns:ns="http://sample.bpel.org/bpel/sampleArtifacts"; xmlns:tns="http://sample.bpel.org/bpel/sample"; exitOnStandardFault="yes" name="OnEventCorrelationB111" suppressJoinFailure="yes" targetNamespace="http://sample.bpel.org/bpel/sample"; expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"> + <bpws:import importType="http://schemas.xmlsoap.org/wsdl/"; location="OnEventCorrelation.wsdl" namespace="http://sample.bpel.org/bpel/sample"/> + <bpws:import importType="http://schemas.xmlsoap.org/wsdl/"; location="OnEventCorrelationArtifacts.wsdl" namespace="http://sample.bpel.org/bpel/sampleArtifacts"/> + <bpws:partnerLinks> + <bpws:partnerLink myRole="OnEventCorrelationProvider" name="client" partnerLinkType="tns:OnEventCorrelation"/> + </bpws:partnerLinks> + <bpws:variables> + <bpws:variable messageType="tns:OnEventCorrelationMessage" name="input"/> + <bpws:variable messageType="tns:OnEventCorrelationMessage" name="output"/> + <bpws:variable type="xsd:string" name="s"/> + </bpws:variables> + <bpws:correlationSets> + <bpws:correlationSet name="CorrelationSet" properties="ns:input"/> + </bpws:correlationSets> + <bpws:sequence name="main"> + + <bpws:receive createInstance="yes" operation="opIn" partnerLink="client" portType="tns:OnEventCorrelation" variable="input"> + <bpws:correlations> + <bpws:correlation initiate="yes" set="CorrelationSet"/> + </bpws:correlations> + </bpws:receive> + + <bpws:assign> + <bpws:copy> + <bpws:from>$input.data</bpws:from> + <bpws:to>$s</bpws:to> + </bpws:copy> + </bpws:assign> + + <bpws:wait><bpws:for>'PT1S'</bpws:for></bpws:wait> + + <bpws:receive createInstance="no" operation="opIn" partnerLink="client" portType="tns:OnEventCorrelation" variable="input"> + <bpws:correlations> + <bpws:correlation initiate="no" set="CorrelationSet"/> + </bpws:correlations> + </bpws:receive> + + <bpws:assign> + <bpws:copy> + <bpws:from>concat($s, $input.data)</bpws:from> + <bpws:to>$s</bpws:to> + </bpws:copy> + </bpws:assign> + + <bpws:wait><bpws:for>'PT1S'</bpws:for></bpws:wait> + + <bpws:receive createInstance="no" operation="opInOut" partnerLink="client" portType="tns:OnEventCorrelation" variable="input" messageExchange="mex1"> + <bpws:correlations> + <bpws:correlation initiate="no" set="CorrelationSet"/> + </bpws:correlations> + </bpws:receive> + <bpws:assign> + <bpws:copy> + <bpws:from>concat($s, $input.data)</bpws:from> + <bpws:to>$s</bpws:to> + </bpws:copy> + </bpws:assign> + <bpws:assign> + <bpws:copy> + <bpws:from>$input.payload</bpws:from> + <bpws:to>$output.payload</bpws:to> + </bpws:copy> + <bpws:copy> + <bpws:from>'r1'</bpws:from> + <bpws:to>$output.data</bpws:to> + </bpws:copy> + </bpws:assign> + <bpws:reply operation="opInOut" partnerLink="client" variable="output" messageExchange="mex1"/> + + <bpws:wait><bpws:for>'PT1S'</bpws:for></bpws:wait> + + <bpws:receive createInstance="no" operation="opInOut" partnerLink="client" portType="tns:OnEventCorrelation" variable="input" messageExchange="mex2"> + <bpws:correlations> + <bpws:correlation initiate="no" set="CorrelationSet"/> + </bpws:correlations> + </bpws:receive> + <bpws:assign> + <bpws:copy> + <bpws:from>concat($s, $input.data)</bpws:from> + <bpws:to>$s</bpws:to> + </bpws:copy> + </bpws:assign> + <bpws:assign> + <bpws:copy> + <bpws:from>$s</bpws:from> + <bpws:to>$output.data</bpws:to> + </bpws:copy> + </bpws:assign> + <bpws:reply operation="opInOut" partnerLink="client" variable="output" messageExchange="mex2"/> + </bpws:sequence> +</bpws:process> +
Added: ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/deploy.xml URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/deploy.xml?rev=811583&view=auto ============================================================================== --- ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/deploy.xml (added) +++ ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/deploy.xml Sat Sep 5 03:34:28 2009 @@ -0,0 +1,163 @@ +<?xml version='1.0' encoding='UTF-8'?> +<!-- + ~ 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. + --> +<dd:deploy xmlns:dd="http://www.apache.org/ode/schemas/dd/2007/03"; + xmlns:bpel="http://sample.bpel.org/bpel/sample"; + > + + + <dd:process name="bpel:OnEventCorrelation000" fileName="OnEventCorrelation000.bpel"> + <!--dd:process-events generate="none"/--> + <dd:in-memory>false</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelation000" port="OnEventCorrelation" /> + </dd:provide> + <dd:invoke partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB000" port="OnEventCorrelationB" /> + </dd:invoke> + </dd:process> + <dd:process name="bpel:OnEventCorrelationB000" fileName="OnEventCorrelationB000.bpel"> + <dd:in-memory>false</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB000" port="OnEventCorrelationB" /> + </dd:provide> + </dd:process> + + <dd:process name="bpel:OnEventCorrelation100" fileName="OnEventCorrelation100.bpel"> + <!--dd:process-events generate="none"/--> + <dd:in-memory>true</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelation100" port="OnEventCorrelation" /> + </dd:provide> + <dd:invoke partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB100" port="OnEventCorrelationB" /> + </dd:invoke> + </dd:process> + <dd:process name="bpel:OnEventCorrelationB100" fileName="OnEventCorrelationB100.bpel"> + <dd:in-memory>false</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB100" port="OnEventCorrelationB" /> + </dd:provide> + </dd:process> + + <dd:process name="bpel:OnEventCorrelation010" fileName="OnEventCorrelation010.bpel"> + <!--dd:process-events generate="none"/--> + <dd:in-memory>false</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelation010" port="OnEventCorrelation" /> + </dd:provide> + <dd:invoke partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB010Fwd" port="OnEventCorrelationB" /> + </dd:invoke> + </dd:process> + <dd:process name="bpel:OnEventCorrelationB010" fileName="OnEventCorrelationB010.bpel"> + <dd:in-memory>false</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB010" port="OnEventCorrelationB" /> + </dd:provide> + </dd:process> + + <dd:process name="bpel:OnEventCorrelation110" fileName="OnEventCorrelation110.bpel"> + <!--dd:process-events generate="none"/--> + <dd:in-memory>true</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelation110" port="OnEventCorrelation" /> + </dd:provide> + <dd:invoke partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB110Fwd" port="OnEventCorrelationB" /> + </dd:invoke> + </dd:process> + <dd:process name="bpel:OnEventCorrelationB110" fileName="OnEventCorrelationB110.bpel"> + <dd:in-memory>false</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB110" port="OnEventCorrelationB" /> + </dd:provide> + </dd:process> + + <dd:process name="bpel:OnEventCorrelation001" fileName="OnEventCorrelation001.bpel"> + <!--dd:process-events generate="none"/--> + <dd:in-memory>false</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelation001" port="OnEventCorrelation" /> + </dd:provide> + <dd:invoke partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB001" port="OnEventCorrelationB" /> + </dd:invoke> + </dd:process> + <dd:process name="bpel:OnEventCorrelationB001" fileName="OnEventCorrelationB001.bpel"> + <dd:in-memory>true</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB001" port="OnEventCorrelationB" /> + </dd:provide> + </dd:process> + + <dd:process name="bpel:OnEventCorrelation101" fileName="OnEventCorrelation101.bpel"> + <!--dd:process-events generate="none"/--> + <dd:in-memory>true</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelation101" port="OnEventCorrelation" /> + </dd:provide> + <dd:invoke partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB101" port="OnEventCorrelationB" /> + </dd:invoke> + </dd:process> + <dd:process name="bpel:OnEventCorrelationB101" fileName="OnEventCorrelationB101.bpel"> + <dd:in-memory>true</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB101" port="OnEventCorrelationB" /> + </dd:provide> + </dd:process> + + <dd:process name="bpel:OnEventCorrelation011" fileName="OnEventCorrelation011.bpel"> + <!--dd:process-events generate="none"/--> + <dd:in-memory>false</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelation011" port="OnEventCorrelation" /> + </dd:provide> + <dd:invoke partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB011Fwd" port="OnEventCorrelationB" /> + </dd:invoke> + </dd:process> + <dd:process name="bpel:OnEventCorrelationB011" fileName="OnEventCorrelationB011.bpel"> + <dd:in-memory>true</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB011" port="OnEventCorrelationB" /> + </dd:provide> + </dd:process> + + <dd:process name="bpel:OnEventCorrelation111" fileName="OnEventCorrelation111.bpel"> + <!--dd:process-events generate="none"/--> + <dd:in-memory>true</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelation111" port="OnEventCorrelation" /> + </dd:provide> + <dd:invoke partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB111Fwd" port="OnEventCorrelationB" /> + </dd:invoke> + </dd:process> + <dd:process name="bpel:OnEventCorrelationB111" fileName="OnEventCorrelationB111.bpel"> + <dd:in-memory>true</dd:in-memory> + <dd:provide partnerLink="client"> + <dd:service name="bpel:OnEventCorrelationB111" port="OnEventCorrelationB" /> + </dd:provide> + </dd:process> + + +</dd:deploy> + Propchange: ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/deploy.xml ------------------------------------------------------------------------------ svn:eol-style = native Added: ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/smx.xml URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/smx.xml?rev=811583&view=auto ============================================================================== --- ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/smx.xml (added) +++ ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/smx.xml Sat Sep 5 03:34:28 2009 @@ -0,0 +1,144 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<beans xmlns:sm="http://servicemix.apache.org/config/1.0"; + xmlns:http="http://servicemix.apache.org/http/1.0"; + xmlns:eip="http://servicemix.apache.org/eip/1.0"; + xmlns:util="http://www.springframework.org/schema/util"; + xmlns:jencks="http://jencks.org/2.0"; + xmlns:mws="http://ode/bpel/unit-test.wsdl"; + xmlns:ws="http://playmobile.pl/process/mnpm/portIn"; + xmlns:sem="http://playmobile.pl/service/mnpm"; + xmlns:bpel="http://sample.bpel.org/bpel/sample"; + > + + <bean id="transactionManager" class="org.apache.geronimo.transaction.manager.GeronimoTransactionManager"/> + + <jencks:connectionTracker id="connectionTracker" geronimoTransactionManager="#transactionManager" /> + + <jencks:workManager + id="workManager" + threadPoolSize="200" + transactionManager="#transactionManager" /> + + <jencks:bootstrapContext + id="bootstrapContext" + workManager="#workManager" + transactionManager="#transactionManager" /> + + <jencks:poolingSupport + id="poolingSupport" + connectionMaxIdleMinutes="5" + poolMaxSize="20" + /> + + <jencks:connectionManager + id="connectionManager" + containerManagedSecurity="false" + transaction="xa" + transactionManager="#transactionManager" + poolingSupport="#poolingSupport" + connectionTracker="#connectionTracker" + /> + + <bean id="localDerbyMCF" class="org.tranql.connector.derby.EmbeddedXAMCF"> + <property name="databaseName" value="target/test/testdb"/> + <property name="createDatabase" value="true"/> + <property name="userName" value = "sa"/> + <property name="password" value = ""/> + </bean> + <bean id="localDerbyDataSource" class="org.springframework.jca.support.LocalConnectionFactoryBean"> + <property name="managedConnectionFactory" ref="localDerbyMCF"/> + <property name="connectionManager" ref="connectionManager"/> + </bean> + + <bean id="jndi" + class="org.apache.xbean.spring.jndi.SpringInitialContextFactory" + factory-method="makeInitialContext" + singleton="true" + depends-on="bootstrapContext" + > + <property name="entries" ref="jndiEntries" /> + </bean> + + <util:map id="jndiEntries"> + <entry key="testds" value-ref="localDerbyDataSource"/> + </util:map> + + + + <sm:container + id="jbi" + embedded="true" + rootDir="target/test/smx" + transactionManager="#transactionManager" + depends-on="jndi" + > + <sm:activationSpecs> + <sm:activationSpec id="ms-eip"> + <sm:component> + <eip:component> + <eip:endpoints> + <eip:content-based-router service="bpel:OnEventCorrelationB010Fwd" endpoint="OnEventCorrelationB" forwardOperation="true"> + <eip:rules> + <eip:routing-rule> + <eip:target> + <eip:exchange-target service="bpel:OnEventCorrelationB010"/> + </eip:target> + </eip:routing-rule> + </eip:rules> + </eip:content-based-router> + + <eip:content-based-router service="bpel:OnEventCorrelationB110Fwd" endpoint="OnEventCorrelationB" forwardOperation="true"> + <eip:rules> + <eip:routing-rule> + <eip:target> + <eip:exchange-target service="bpel:OnEventCorrelationB110"/> + </eip:target> + </eip:routing-rule> + </eip:rules> + </eip:content-based-router> + + <eip:content-based-router service="bpel:OnEventCorrelationB011Fwd" endpoint="OnEventCorrelationB" forwardOperation="true"> + <eip:rules> + <eip:routing-rule> + <eip:target> + <eip:exchange-target service="bpel:OnEventCorrelationB011"/> + </eip:target> + </eip:routing-rule> + </eip:rules> + </eip:content-based-router> + + <eip:content-based-router service="bpel:OnEventCorrelationB111Fwd" endpoint="OnEventCorrelationB" forwardOperation="true"> + <eip:rules> + <eip:routing-rule> + <eip:target> + <eip:exchange-target service="bpel:OnEventCorrelationB111"/> + </eip:target> + </eip:routing-rule> + </eip:rules> + </eip:content-based-router> + + </eip:endpoints> + </eip:component> + </sm:component> + </sm:activationSpec> + </sm:activationSpecs> + </sm:container> +</beans> Propchange: ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/smx.xml ------------------------------------------------------------------------------ svn:eol-style = native Added: ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/test.properties URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/test.properties?rev=811583&view=auto ============================================================================== --- ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/test.properties (added) +++ ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/test.properties Sat Sep 5 03:34:28 2009 @@ -0,0 +1,22 @@ +# +# 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. +# + +nmr.service={http://sample.bpel.org/bpel/sample}OnEventCorrelation010 +nmr.operation=opInOut +request=<msg><payload>abc3-010</payload><data>t3-010</data></msg> +response=.*result-r1tIn1tIn2tInOut3tInOut4.* + Propchange: ode/branches/APACHE_ODE_1.X/jbi/src/test/resources/CommunicationJbiTest/test.properties ------------------------------------------------------------------------------ svn:eol-style = native
