RiftSaw-postgres - Build # 180 - Failure!
by jboss-qa-internal＠redhat.com
RiftSaw-postgres Build number 180 status: Failure
Details available at http://hudson.jboss.org/hudson/job/RiftSaw-postgres/180/
14 years, 11 months
- 1
- 0
Hudson build became unstable: RiftSaw-postgres-2.1.x #53
by jboss-qa-internal＠redhat.com
See <http://hudson.qa.jboss.com/hudson/job/RiftSaw-postgres-2.1.x/53/changes>
14 years, 11 months
- 1
- 1
riftsaw SVN: r1036 - branches/RiftSaw-2.1.x/integration-tests.
by riftsaw-commits＠lists.jboss.org
Author: objectiser
Date: 2010-10-12 12:52:59 -0400 (Tue, 12 Oct 2010)
New Revision: 1036
Modified:
branches/RiftSaw-2.1.x/integration-tests/
Log:
Property changes on: branches/RiftSaw-2.1.x/integration-tests
___________________________________________________________________
Name: svn:ignore
- target
.classpath
.project
.settings
+ target
.classpath
.project
.settings
downloads
14 years, 11 months
- 1
- 0
riftsaw SVN: r1035 - in branches/RiftSaw-2.1.x/integration-tests: src/test/java/org/jboss/soa/bpel/tests/testcases and 7 other directories.
by riftsaw-commits＠lists.jboss.org
Author: objectiser
Date: 2010-10-12 12:49:52 -0400 (Tue, 12 Oct 2010)
New Revision: 1035
Added:
branches/RiftSaw-2.1.x/integration-tests/src/test/java/org/jboss/soa/bpel/tests/testcases/RiftSaw299PeerTestCase.java
branches/RiftSaw-2.1.x/integration-tests/src/test/java/org/jboss/soa/bpel/tests/testcases/RiftSaw299WSTestCase.java
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Goodbye.bpel
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Goodbye.wsdl
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Hello.bpel
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Hello.wsdl
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/deploy.xml
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/build.xml
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/hello_request1.xml
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/hello_response1.xml
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Goodbye.bpel
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Goodbye.wsdl
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Hello.bpel
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Hello.wsdl
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/deploy.xml
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/build.xml
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/hello_request1.xml
branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/hello_response1.xml
Modified:
branches/RiftSaw-2.1.x/integration-tests/build.xml
Log:
Added tests for RIFTSAW-299 - a peer to peer version and one that uses the web service stack between the two BPEL processes.
Modified: branches/RiftSaw-2.1.x/integration-tests/build.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/build.xml 2010-10-12 12:34:16 UTC (rev 1034)
+++ branches/RiftSaw-2.1.x/integration-tests/build.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -191,6 +191,8 @@
<ant antfile="src/test/resources/testcases/RiftSaw_279/build.xml" />
<ant antfile="src/test/resources/testcases/RiftSaw_285/build.xml" />
<ant antfile="src/test/resources/testcases/RiftSaw_296/build.xml" />
+ <ant antfile="src/test/resources/testcases/RiftSaw_299_peer/build.xml" />
+ <ant antfile="src/test/resources/testcases/RiftSaw_299_ws/build.xml" />
<ant antfile="src/test/resources/tutorials/BluePrint1/build.xml" />
<ant antfile="src/test/resources/tutorials/BluePrint2/build.xml" />
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/java/org/jboss/soa/bpel/tests/testcases/RiftSaw299PeerTestCase.java
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/java/org/jboss/soa/bpel/tests/testcases/RiftSaw299PeerTestCase.java (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/java/org/jboss/soa/bpel/tests/testcases/RiftSaw299PeerTestCase.java 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,53 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.soa.bpel.tests.testcases;
+
+import org.jboss.soa.bpel.tests.RiftSawTest;
+import org.jboss.soa.bpel.tests.RiftSawTestSetup;
+
+import junit.framework.Test;
+
+/**
+ * Test case for RiftSaw_299
+ */
+public class RiftSaw299PeerTestCase extends RiftSawTest {
+
+ private static final String TEST_NAME = "RiftSaw_299_peer";
+
+ public RiftSaw299PeerTestCase() {
+ super(TEST_NAME);
+ }
+
+ public static Test suite() {
+ return(new RiftSawTestSetup(RiftSaw299PeerTestCase.class,
+ TEST_NAME, "RiftSaw_299_peer-1.jar"));
+ }
+
+ public void testSendHello() throws Exception {
+ String result1=sendSOAPMessage("hello_request1.xml",
+ "http://localhost:8080/RiftSaw_299_helloWS");
+
+ result1 = processResult(result1);
+
+ assertMessageFromFile(result1, "hello_response1.xml");
+ }
+}
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/java/org/jboss/soa/bpel/tests/testcases/RiftSaw299WSTestCase.java
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/java/org/jboss/soa/bpel/tests/testcases/RiftSaw299WSTestCase.java (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/java/org/jboss/soa/bpel/tests/testcases/RiftSaw299WSTestCase.java 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,53 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.soa.bpel.tests.testcases;
+
+import org.jboss.soa.bpel.tests.RiftSawTest;
+import org.jboss.soa.bpel.tests.RiftSawTestSetup;
+
+import junit.framework.Test;
+
+/**
+ * Test case for RiftSaw_299
+ */
+public class RiftSaw299WSTestCase extends RiftSawTest {
+
+ private static final String TEST_NAME = "RiftSaw_299_ws";
+
+ public RiftSaw299WSTestCase() {
+ super(TEST_NAME);
+ }
+
+ public static Test suite() {
+ return(new RiftSawTestSetup(RiftSaw299WSTestCase.class,
+ TEST_NAME, "RiftSaw_299_ws-1.jar"));
+ }
+
+ public void testSendHello() throws Exception {
+ String result1=sendSOAPMessage("hello_request1.xml",
+ "http://localhost:8080/RiftSaw_299_helloWS");
+
+ result1 = processResult(result1);
+
+ assertMessageFromFile(result1, "hello_response1.xml");
+ }
+}
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Goodbye.bpel
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Goodbye.bpel (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Goodbye.bpel 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,119 @@
+<!--
+ ~ 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.
+ -->
+<process name="Goodbye"
+ targetNamespace="http://www.jboss.org/bpel/examples"
+ xmlns="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
+ xmlns:tns="http://www.jboss.org/bpel/examples"
+ xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+ xmlns:intf="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:intf2="http://www.jboss.org/bpel/examples/wsdl2"
+ queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"
+ expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0">
+
+ <import location="Hello.wsdl"
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ importType="http://schemas.xmlsoap.org/wsdl/" />
+
+ <import location="Goodbye.wsdl"
+ namespace="http://www.jboss.org/bpel/examples/wsdl2"
+ importType="http://schemas.xmlsoap.org/wsdl/" />
+
+ <partnerLinks>
+ <partnerLink name="goodbyePartnerLink"
+ partnerLinkType="intf2:GoodbyePartnerLinkType"
+ myRole="me" />
+ <partnerLink name="helloCallbackPartnerLink"
+ partnerLinkType="intf:HelloCallbackPartnerLinkType"
+ partnerRole="you"
+ initializePartnerRole="yes"/>
+ </partnerLinks>
+
+ <correlationSets xmlns:cor="http://example.com/supplyCorrelation">
+ <correlationSet name="Session"
+ properties="intf2:SessionID" />
+ </correlationSets>
+
+ <variables>
+ <variable name="myGoodbyeVar" messageType="intf2:GoodbyeMessage"/>
+ <variable name="mesgVar" type="xsd:string"/>
+ <variable name="myHelloVar" messageType="intf:HelloMessage"/>
+ </variables>
+
+ <sequence>
+ <receive
+ name="start"
+ partnerLink="goodbyePartnerLink"
+ portType="intf2:GoodbyePortType"
+ operation="goodbye"
+ variable="myGoodbyeVar"
+ createInstance="yes">
+ <correlations>
+ <correlation set="Session" initiate="yes" />
+ </correlations>
+ </receive>
+
+ <assign name="assignGoodbyeMesg">
+ <copy>
+ <from variable="myGoodbyeVar" part="Message"/>
+ <to variable="mesgVar"/>
+ </copy>
+ <copy>
+ <from>concat($mesgVar,' World')</from>
+ <to variable="myGoodbyeVar" part="Message"/>
+ </copy>
+ </assign>
+ <reply name="end"
+ partnerLink="goodbyePartnerLink"
+ portType="intf2:GoodbyePortType"
+ operation="goodbye"
+ variable="myGoodbyeVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </reply>
+
+ <assign name="assignGoodbyeMesg">
+ <copy>
+ <from variable="myGoodbyeVar" part="Message"/>
+ <to variable="mesgVar"/>
+ </copy>
+ <copy>
+ <from>concat($mesgVar,' Callback')</from>
+ <to variable="myHelloVar" part="Message"/>
+ </copy>
+ </assign>
+ <assign name="assignGoodbyeMesg2">
+ <copy>
+ <from variable="myGoodbyeVar" part="ID"/>
+ <to variable="myHelloVar" part="ID" />
+ </copy>
+ </assign>
+
+ <invoke name="ICallTheCallbackService"
+ partnerLink="helloCallbackPartnerLink"
+ portType="intf:HelloCallbackPortType"
+ operation="helloCallback"
+ inputVariable="myHelloVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </invoke>
+
+ </sequence>
+</process>
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Goodbye.wsdl
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Goodbye.wsdl (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Goodbye.wsdl 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,95 @@
+<?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.
+ -->
+<wsdl:definitions
+ targetNamespace="http://www.jboss.org/bpel/examples/wsdl2"
+ xmlns="http://schemas.xmlsoap.org/wsdl/"
+ xmlns:tns="http://www.jboss.org/bpel/examples/wsdl2"
+ xmlns:intf="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:types="http://www.jboss.org/bpel/examples/xsd"
+ xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"
+ xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+ xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"
+ xmlns:vprop="http://docs.oasis-open.org/wsbpel/2.0/varprop"
+ xmlns:plnk="http://docs.oasis-open.org/wsbpel/2.0/plnktype">
+
+ <wsdl:types>
+ <xsd:schema targetNamespace="http://www.jboss.org/bpel/examples/xsd">
+ <xsd:complexType name="SessionIdentity">
+ <xsd:sequence>
+ <xsd:element name="id" type="xsd:int" />
+ </xsd:sequence>
+ </xsd:complexType>
+ </xsd:schema>
+ </wsdl:types>
+
+ <wsdl:message name="GoodbyeMessage">
+ <wsdl:part name="ID" type="types:SessionIdentity"/>
+ <wsdl:part name="Message" type="xsd:string"/>
+ </wsdl:message>
+
+ <wsdl:portType name="GoodbyePortType">
+ <wsdl:operation name="goodbye">
+ <wsdl:input message="tns:GoodbyeMessage" name="GoodbyeIn"/>
+ <wsdl:output message="tns:GoodbyeMessage" name="GoodbyeOut"/>
+ </wsdl:operation>
+ </wsdl:portType>
+
+ <wsdl:binding name="GoodbyeSoapBinding" type="tns:GoodbyePortType">
+ <soap:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/>
+ <wsdl:operation name="goodbye">
+ <soap:operation soapAction="" style="rpc"/>
+ <wsdl:input>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl2"
+ use="literal"/>
+ </wsdl:input>
+ <wsdl:output>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl2"
+ use="literal"/>
+ </wsdl:output>
+ </wsdl:operation>
+ </wsdl:binding>
+ <wsdl:service name="GoodbyeService">
+ <wsdl:port name="GoodbyePort" binding="tns:GoodbyeSoapBinding">
+ <soap:address location="http://localhost:8080/RiftSaw_299_goodbyeWS"/>
+ </wsdl:port>
+ </wsdl:service>
+
+ <plnk:partnerLinkType name="GoodbyePartnerLinkType">
+ <plnk:role name="me" portType="tns:GoodbyePortType"/>
+ <plnk:role name="you" portType="tns:GoodbyePortType"/>
+ </plnk:partnerLinkType>
+
+ <vprop:property name="SessionID" type="xsd:int" />
+
+ <vprop:propertyAlias propertyName="tns:SessionID"
+ messageType="tns:GoodbyeMessage" part="ID">
+ <vprop:query>id</vprop:query>
+ </vprop:propertyAlias>
+
+ <vprop:propertyAlias propertyName="tns:SessionID"
+ messageType="intf:HelloMessage" part="ID">
+ <vprop:query>id</vprop:query>
+ </vprop:propertyAlias>
+
+
+</wsdl:definitions>
+
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Hello.bpel
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Hello.bpel (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Hello.bpel 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,129 @@
+<!--
+ ~ 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.
+ -->
+<process name="Hello"
+ targetNamespace="http://www.jboss.org/bpel/examples"
+ xmlns="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
+ xmlns:tns="http://www.jboss.org/bpel/examples"
+ xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+ xmlns:intf="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:intf2="http://www.jboss.org/bpel/examples/wsdl2"
+ queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"
+ expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0">
+
+ <import location="Hello.wsdl"
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ importType="http://schemas.xmlsoap.org/wsdl/" />
+
+ <import location="Goodbye.wsdl"
+ namespace="http://www.jboss.org/bpel/examples/wsdl2"
+ importType="http://schemas.xmlsoap.org/wsdl/" />
+
+ <partnerLinks>
+ <partnerLink name="helloPartnerLink"
+ partnerLinkType="intf:HelloPartnerLinkType"
+ myRole="me" />
+ <partnerLink name="helloCallbackPartnerLink"
+ partnerLinkType="intf:HelloCallbackPartnerLinkType"
+ myRole="me" />
+ <partnerLink name="goodbyePartnerLink"
+ partnerLinkType="intf2:GoodbyePartnerLinkType"
+ partnerRole="you"
+ initializePartnerRole="yes"/>
+ </partnerLinks>
+
+ <correlationSets xmlns:cor="http://example.com/supplyCorrelation">
+ <correlationSet name="Session"
+ properties="intf:SessionID" />
+ </correlationSets>
+
+ <variables>
+ <variable name="myHelloVar" messageType="intf:HelloMessage"/>
+ <variable name="inVar" messageType="intf2:GoodbyeMessage"/>
+ <variable name="outVar" messageType="intf2:GoodbyeMessage"/>
+ <variable name="callbackVar" messageType="intf:HelloMessage"/>
+ <variable name="mesgVar" type="xsd:string"/>
+ </variables>
+
+ <sequence>
+ <receive
+ name="start"
+ partnerLink="helloPartnerLink"
+ portType="intf:HelloPortType"
+ operation="hello"
+ variable="myHelloVar"
+ createInstance="yes">
+ <correlations>
+ <correlation set="Session" initiate="yes" />
+ </correlations>
+ </receive>
+
+ <assign name="assignHelloMesg">
+ <copy>
+ <from variable="myHelloVar" part="Message"/>
+ <to variable="inVar" part="Message" />
+ </copy>
+ <copy>
+ <from variable="myHelloVar" part="ID"/>
+ <to variable="inVar" part="ID" />
+ </copy>
+ </assign>
+
+ <invoke name="ICallTheExternalService"
+ partnerLink="goodbyePartnerLink"
+ portType="intf2:GoodbyePortType"
+ operation="goodbye"
+ inputVariable="inVar" outputVariable="outVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </invoke>
+
+ <receive
+ name="callback"
+ partnerLink="helloCallbackPartnerLink"
+ portType="intf:HelloCallbackPortType"
+ operation="helloCallback"
+ variable="callbackVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </receive>
+
+ <assign name="assignHelloMesg">
+ <copy>
+ <from variable="myHelloVar" part="Message"/>
+ <to variable="mesgVar"/>
+ </copy>
+ <copy>
+ <from>concat($mesgVar,' World')</from>
+ <to variable="myHelloVar" part="Message"/>
+ </copy>
+ </assign>
+
+ <reply name="end"
+ partnerLink="helloPartnerLink"
+ portType="intf:HelloPortType"
+ operation="hello"
+ variable="myHelloVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </reply>
+ </sequence>
+</process>
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Hello.wsdl
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Hello.wsdl (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/Hello.wsdl 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,114 @@
+<?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.
+ -->
+<wsdl:definitions
+ targetNamespace="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns="http://schemas.xmlsoap.org/wsdl/"
+ xmlns:tns="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:types="http://www.jboss.org/bpel/examples/xsd"
+ xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"
+ xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+ xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"
+ xmlns:vprop="http://docs.oasis-open.org/wsbpel/2.0/varprop"
+ xmlns:plnk="http://docs.oasis-open.org/wsbpel/2.0/plnktype">
+
+ <wsdl:types>
+ <xsd:schema targetNamespace="http://www.jboss.org/bpel/examples/xsd">
+ <xsd:complexType name="SessionIdentity">
+ <xsd:sequence>
+ <xsd:element name="id" type="xsd:int" />
+ </xsd:sequence>
+ </xsd:complexType>
+ </xsd:schema>
+ </wsdl:types>
+
+ <wsdl:message name="HelloMessage">
+ <wsdl:part name="ID" type="types:SessionIdentity"/>
+ <wsdl:part name="Message" type="xsd:string"/>
+ </wsdl:message>
+
+ <wsdl:portType name="HelloPortType">
+ <wsdl:operation name="hello">
+ <wsdl:input message="tns:HelloMessage" name="HelloIn"/>
+ <wsdl:output message="tns:HelloMessage" name="HelloOut"/>
+ </wsdl:operation>
+ </wsdl:portType>
+
+ <wsdl:portType name="HelloCallbackPortType">
+ <wsdl:operation name="helloCallback">
+ <wsdl:input message="tns:HelloMessage" name="HelloCallbackIn"/>
+ </wsdl:operation>
+ </wsdl:portType>
+
+ <wsdl:binding name="HelloSoapBinding" type="tns:HelloPortType">
+ <soap:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/>
+ <wsdl:operation name="hello">
+ <soap:operation soapAction="" style="rpc"/>
+ <wsdl:input>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ use="literal"/>
+ </wsdl:input>
+ <wsdl:output>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ use="literal"/>
+ </wsdl:output>
+ </wsdl:operation>
+ </wsdl:binding>
+ <wsdl:binding name="HelloCallbackSoapBinding" type="tns:HelloCallbackPortType">
+ <soap:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/>
+ <wsdl:operation name="helloCallback">
+ <soap:operation soapAction="" style="rpc"/>
+ <wsdl:input>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ use="literal"/>
+ </wsdl:input>
+ </wsdl:operation>
+ </wsdl:binding>
+ <wsdl:service name="HelloService">
+ <wsdl:port name="HelloPort" binding="tns:HelloSoapBinding">
+ <soap:address location="http://localhost:8080/RiftSaw_299_helloWS"/>
+ </wsdl:port>
+ <wsdl:port name="HelloCallbackPort" binding="tns:HelloCallbackSoapBinding">
+ <soap:address location="http://localhost:8080/RiftSaw_299_helloCallbackWS"/>
+ </wsdl:port>
+ </wsdl:service>
+
+ <plnk:partnerLinkType name="HelloPartnerLinkType">
+ <plnk:role name="me" portType="tns:HelloPortType"/>
+ <plnk:role name="you" portType="tns:HelloPortType"/>
+ </plnk:partnerLinkType>
+
+ <plnk:partnerLinkType name="HelloCallbackPartnerLinkType">
+ <plnk:role name="me" portType="tns:HelloCallbackPortType"/>
+ <plnk:role name="you" portType="tns:HelloCallbackPortType"/>
+ </plnk:partnerLinkType>
+
+ <vprop:property name="SessionID" type="xsd:int" />
+
+ <vprop:propertyAlias propertyName="tns:SessionID"
+ messageType="tns:HelloMessage" part="ID">
+ <vprop:query>id</vprop:query>
+ </vprop:propertyAlias>
+
+
+</wsdl:definitions>
+
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/deploy.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/deploy.xml (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/bpel/deploy.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,46 @@
+<!--
+ ~ 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.
+ -->
+<deploy xmlns="http://www.apache.org/ode/schemas/dd/2007/03"
+ xmlns:bpl="http://www.jboss.org/bpel/examples"
+ xmlns:intf="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:intf2="http://www.jboss.org/bpel/examples/wsdl2">
+
+ <process name="bpl:Hello">
+ <active>true</active>
+ <provide partnerLink="helloPartnerLink">
+ <service name="intf:HelloService" port="HelloPort"/>
+ </provide>
+ <provide partnerLink="helloCallbackPartnerLink">
+ <service name="intf:HelloService" port="HelloCallbackPort"/>
+ </provide>
+ <invoke partnerLink="goodbyePartnerLink" >
+ <service name="intf2:GoodbyeService" port="GoodbyePort" />
+ </invoke>
+ </process>
+
+ <process name="bpl:Goodbye">
+ <active>true</active>
+ <provide partnerLink="goodbyePartnerLink">
+ <service name="intf2:GoodbyeService" port="GoodbyePort"/>
+ </provide>
+ <invoke partnerLink="helloCallbackPartnerLink" >
+ <service name="intf:HelloService" port="HelloCallbackPort" />
+ </invoke>
+ </process>
+</deploy>
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/build.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/build.xml (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/build.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,29 @@
+<project name="RiftSaw_299_peer" default="deploy" basedir=".">
+
+ <description>
+ ${ant.project.name}
+ ${line.separator}
+ </description>
+
+ <property name="version" value="1" />
+
+ <property name="deploy.dir" value="${basedir}/target/tests"/>
+ <property name="test.dir" value="${basedir}/src/test/resources/testcases/${ant.project.name}"/>
+
+ <property name="sample.jar.name" value="${ant.project.name}-${version}.jar" />
+
+ <target name="deploy">
+ <echo>Deploy ${ant.project.name}</echo>
+ <mkdir dir="${deploy.dir}/${ant.project.name}" />
+ <jar basedir="${test.dir}/bpel" destfile="${deploy.dir}/${ant.project.name}/${sample.jar.name}" />
+
+ <copy todir="${deploy.dir}/${ant.project.name}">
+ <fileset dir="${test.dir}/messages"/>
+ </copy>
+ </target>
+
+ <target name="undeploy">
+ <echo>Undeploy ${ant.project.name}</echo>
+ <delete file="${deploy.dir}/${sample.jar.name}" />
+ </target>
+</project>
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/hello_request1.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/hello_request1.xml (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/hello_request1.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,11 @@
+<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:wsdl="http://www.jboss.org/bpel/examples/wsdl">
+ <soapenv:Header/>
+ <soapenv:Body>
+ <wsdl:hello>
+ <ID>
+ <id>1</id>
+ </ID>
+ <Message>Hello</Message>
+ </wsdl:hello>
+ </soapenv:Body>
+</soapenv:Envelope>
\ No newline at end of file
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/hello_response1.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/hello_response1.xml (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_peer/messages/hello_response1.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,3 @@
+<env:Envelope xmlns:env='http://schemas.xmlsoap.org/soap/envelope/'><env:Header></env:Header><env:Body><odens:helloResponse xmlns:odens='http://www.jboss.org/bpel/examples/wsdl'><ID>
+ <id>1</id>
+ </ID><Message>Hello World</Message></odens:helloResponse></env:Body></env:Envelope>
\ No newline at end of file
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Goodbye.bpel
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Goodbye.bpel (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Goodbye.bpel 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,119 @@
+<!--
+ ~ 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.
+ -->
+<process name="Goodbye"
+ targetNamespace="http://www.jboss.org/bpel/examples"
+ xmlns="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
+ xmlns:tns="http://www.jboss.org/bpel/examples"
+ xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+ xmlns:intf="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:intf2="http://www.jboss.org/bpel/examples/wsdl2"
+ queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"
+ expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0">
+
+ <import location="Hello.wsdl"
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ importType="http://schemas.xmlsoap.org/wsdl/" />
+
+ <import location="Goodbye.wsdl"
+ namespace="http://www.jboss.org/bpel/examples/wsdl2"
+ importType="http://schemas.xmlsoap.org/wsdl/" />
+
+ <partnerLinks>
+ <partnerLink name="goodbyePartnerLink"
+ partnerLinkType="intf2:GoodbyePartnerLinkType"
+ myRole="me" />
+ <partnerLink name="helloCallbackPartnerLink"
+ partnerLinkType="intf:HelloCallbackPartnerLinkType"
+ partnerRole="you"
+ initializePartnerRole="yes"/>
+ </partnerLinks>
+
+ <correlationSets xmlns:cor="http://example.com/supplyCorrelation">
+ <correlationSet name="Session"
+ properties="intf2:SessionID" />
+ </correlationSets>
+
+ <variables>
+ <variable name="myGoodbyeVar" messageType="intf2:GoodbyeMessage"/>
+ <variable name="mesgVar" type="xsd:string"/>
+ <variable name="myHelloVar" messageType="intf:HelloMessage"/>
+ </variables>
+
+ <sequence>
+ <receive
+ name="start"
+ partnerLink="goodbyePartnerLink"
+ portType="intf2:GoodbyePortType"
+ operation="goodbye"
+ variable="myGoodbyeVar"
+ createInstance="yes">
+ <correlations>
+ <correlation set="Session" initiate="yes" />
+ </correlations>
+ </receive>
+
+ <assign name="assignGoodbyeMesg">
+ <copy>
+ <from variable="myGoodbyeVar" part="Message"/>
+ <to variable="mesgVar"/>
+ </copy>
+ <copy>
+ <from>concat($mesgVar,' World')</from>
+ <to variable="myGoodbyeVar" part="Message"/>
+ </copy>
+ </assign>
+ <reply name="end"
+ partnerLink="goodbyePartnerLink"
+ portType="intf2:GoodbyePortType"
+ operation="goodbye"
+ variable="myGoodbyeVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </reply>
+
+ <assign name="assignGoodbyeMesg">
+ <copy>
+ <from variable="myGoodbyeVar" part="Message"/>
+ <to variable="mesgVar"/>
+ </copy>
+ <copy>
+ <from>concat($mesgVar,' Callback')</from>
+ <to variable="myHelloVar" part="Message"/>
+ </copy>
+ </assign>
+ <assign name="assignGoodbyeMesg2">
+ <copy>
+ <from variable="myGoodbyeVar" part="ID"/>
+ <to variable="myHelloVar" part="ID" />
+ </copy>
+ </assign>
+
+ <invoke name="ICallTheCallbackService"
+ partnerLink="helloCallbackPartnerLink"
+ portType="intf:HelloCallbackPortType"
+ operation="helloCallback"
+ inputVariable="myHelloVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </invoke>
+
+ </sequence>
+</process>
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Goodbye.wsdl
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Goodbye.wsdl (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Goodbye.wsdl 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,95 @@
+<?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.
+ -->
+<wsdl:definitions
+ targetNamespace="http://www.jboss.org/bpel/examples/wsdl2"
+ xmlns="http://schemas.xmlsoap.org/wsdl/"
+ xmlns:tns="http://www.jboss.org/bpel/examples/wsdl2"
+ xmlns:intf="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:types="http://www.jboss.org/bpel/examples/xsd"
+ xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"
+ xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+ xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"
+ xmlns:vprop="http://docs.oasis-open.org/wsbpel/2.0/varprop"
+ xmlns:plnk="http://docs.oasis-open.org/wsbpel/2.0/plnktype">
+
+ <wsdl:types>
+ <xsd:schema targetNamespace="http://www.jboss.org/bpel/examples/xsd">
+ <xsd:complexType name="SessionIdentity">
+ <xsd:sequence>
+ <xsd:element name="id" type="xsd:int" />
+ </xsd:sequence>
+ </xsd:complexType>
+ </xsd:schema>
+ </wsdl:types>
+
+ <wsdl:message name="GoodbyeMessage">
+ <wsdl:part name="ID" type="types:SessionIdentity"/>
+ <wsdl:part name="Message" type="xsd:string"/>
+ </wsdl:message>
+
+ <wsdl:portType name="GoodbyePortType">
+ <wsdl:operation name="goodbye">
+ <wsdl:input message="tns:GoodbyeMessage" name="GoodbyeIn"/>
+ <wsdl:output message="tns:GoodbyeMessage" name="GoodbyeOut"/>
+ </wsdl:operation>
+ </wsdl:portType>
+
+ <wsdl:binding name="GoodbyeSoapBinding" type="tns:GoodbyePortType">
+ <soap:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/>
+ <wsdl:operation name="goodbye">
+ <soap:operation soapAction="" style="rpc"/>
+ <wsdl:input>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl2"
+ use="literal"/>
+ </wsdl:input>
+ <wsdl:output>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl2"
+ use="literal"/>
+ </wsdl:output>
+ </wsdl:operation>
+ </wsdl:binding>
+ <wsdl:service name="GoodbyeService">
+ <wsdl:port name="GoodbyePort" binding="tns:GoodbyeSoapBinding">
+ <soap:address location="http://localhost:8080/RiftSaw_299_goodbyeWS"/>
+ </wsdl:port>
+ </wsdl:service>
+
+ <plnk:partnerLinkType name="GoodbyePartnerLinkType">
+ <plnk:role name="me" portType="tns:GoodbyePortType"/>
+ <plnk:role name="you" portType="tns:GoodbyePortType"/>
+ </plnk:partnerLinkType>
+
+ <vprop:property name="SessionID" type="xsd:int" />
+
+ <vprop:propertyAlias propertyName="tns:SessionID"
+ messageType="tns:GoodbyeMessage" part="ID">
+ <vprop:query>id</vprop:query>
+ </vprop:propertyAlias>
+
+ <vprop:propertyAlias propertyName="tns:SessionID"
+ messageType="intf:HelloMessage" part="ID">
+ <vprop:query>id</vprop:query>
+ </vprop:propertyAlias>
+
+
+</wsdl:definitions>
+
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Hello.bpel
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Hello.bpel (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Hello.bpel 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,129 @@
+<!--
+ ~ 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.
+ -->
+<process name="Hello"
+ targetNamespace="http://www.jboss.org/bpel/examples"
+ xmlns="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
+ xmlns:tns="http://www.jboss.org/bpel/examples"
+ xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+ xmlns:intf="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:intf2="http://www.jboss.org/bpel/examples/wsdl2"
+ queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"
+ expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0">
+
+ <import location="Hello.wsdl"
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ importType="http://schemas.xmlsoap.org/wsdl/" />
+
+ <import location="Goodbye.wsdl"
+ namespace="http://www.jboss.org/bpel/examples/wsdl2"
+ importType="http://schemas.xmlsoap.org/wsdl/" />
+
+ <partnerLinks>
+ <partnerLink name="helloPartnerLink"
+ partnerLinkType="intf:HelloPartnerLinkType"
+ myRole="me" />
+ <partnerLink name="helloCallbackPartnerLink"
+ partnerLinkType="intf:HelloCallbackPartnerLinkType"
+ myRole="me" />
+ <partnerLink name="goodbyePartnerLink"
+ partnerLinkType="intf2:GoodbyePartnerLinkType"
+ partnerRole="you"
+ initializePartnerRole="yes"/>
+ </partnerLinks>
+
+ <correlationSets xmlns:cor="http://example.com/supplyCorrelation">
+ <correlationSet name="Session"
+ properties="intf:SessionID" />
+ </correlationSets>
+
+ <variables>
+ <variable name="myHelloVar" messageType="intf:HelloMessage"/>
+ <variable name="inVar" messageType="intf2:GoodbyeMessage"/>
+ <variable name="outVar" messageType="intf2:GoodbyeMessage"/>
+ <variable name="callbackVar" messageType="intf:HelloMessage"/>
+ <variable name="mesgVar" type="xsd:string"/>
+ </variables>
+
+ <sequence>
+ <receive
+ name="start"
+ partnerLink="helloPartnerLink"
+ portType="intf:HelloPortType"
+ operation="hello"
+ variable="myHelloVar"
+ createInstance="yes">
+ <correlations>
+ <correlation set="Session" initiate="yes" />
+ </correlations>
+ </receive>
+
+ <assign name="assignHelloMesg">
+ <copy>
+ <from variable="myHelloVar" part="Message"/>
+ <to variable="inVar" part="Message" />
+ </copy>
+ <copy>
+ <from variable="myHelloVar" part="ID"/>
+ <to variable="inVar" part="ID" />
+ </copy>
+ </assign>
+
+ <invoke name="ICallTheExternalService"
+ partnerLink="goodbyePartnerLink"
+ portType="intf2:GoodbyePortType"
+ operation="goodbye"
+ inputVariable="inVar" outputVariable="outVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </invoke>
+
+ <receive
+ name="callback"
+ partnerLink="helloCallbackPartnerLink"
+ portType="intf:HelloCallbackPortType"
+ operation="helloCallback"
+ variable="callbackVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </receive>
+
+ <assign name="assignHelloMesg">
+ <copy>
+ <from variable="myHelloVar" part="Message"/>
+ <to variable="mesgVar"/>
+ </copy>
+ <copy>
+ <from>concat($mesgVar,' World')</from>
+ <to variable="myHelloVar" part="Message"/>
+ </copy>
+ </assign>
+
+ <reply name="end"
+ partnerLink="helloPartnerLink"
+ portType="intf:HelloPortType"
+ operation="hello"
+ variable="myHelloVar">
+ <correlations>
+ <correlation set="Session" initiate="no" />
+ </correlations>
+ </reply>
+ </sequence>
+</process>
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Hello.wsdl
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Hello.wsdl (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/Hello.wsdl 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,114 @@
+<?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.
+ -->
+<wsdl:definitions
+ targetNamespace="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns="http://schemas.xmlsoap.org/wsdl/"
+ xmlns:tns="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:types="http://www.jboss.org/bpel/examples/xsd"
+ xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"
+ xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+ xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"
+ xmlns:vprop="http://docs.oasis-open.org/wsbpel/2.0/varprop"
+ xmlns:plnk="http://docs.oasis-open.org/wsbpel/2.0/plnktype">
+
+ <wsdl:types>
+ <xsd:schema targetNamespace="http://www.jboss.org/bpel/examples/xsd">
+ <xsd:complexType name="SessionIdentity">
+ <xsd:sequence>
+ <xsd:element name="id" type="xsd:int" />
+ </xsd:sequence>
+ </xsd:complexType>
+ </xsd:schema>
+ </wsdl:types>
+
+ <wsdl:message name="HelloMessage">
+ <wsdl:part name="ID" type="types:SessionIdentity"/>
+ <wsdl:part name="Message" type="xsd:string"/>
+ </wsdl:message>
+
+ <wsdl:portType name="HelloPortType">
+ <wsdl:operation name="hello">
+ <wsdl:input message="tns:HelloMessage" name="HelloIn"/>
+ <wsdl:output message="tns:HelloMessage" name="HelloOut"/>
+ </wsdl:operation>
+ </wsdl:portType>
+
+ <wsdl:portType name="HelloCallbackPortType">
+ <wsdl:operation name="helloCallback">
+ <wsdl:input message="tns:HelloMessage" name="HelloCallbackIn"/>
+ </wsdl:operation>
+ </wsdl:portType>
+
+ <wsdl:binding name="HelloSoapBinding" type="tns:HelloPortType">
+ <soap:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/>
+ <wsdl:operation name="hello">
+ <soap:operation soapAction="" style="rpc"/>
+ <wsdl:input>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ use="literal"/>
+ </wsdl:input>
+ <wsdl:output>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ use="literal"/>
+ </wsdl:output>
+ </wsdl:operation>
+ </wsdl:binding>
+ <wsdl:binding name="HelloCallbackSoapBinding" type="tns:HelloCallbackPortType">
+ <soap:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/>
+ <wsdl:operation name="helloCallback">
+ <soap:operation soapAction="" style="rpc"/>
+ <wsdl:input>
+ <soap:body
+ namespace="http://www.jboss.org/bpel/examples/wsdl"
+ use="literal"/>
+ </wsdl:input>
+ </wsdl:operation>
+ </wsdl:binding>
+ <wsdl:service name="HelloService">
+ <wsdl:port name="HelloPort" binding="tns:HelloSoapBinding">
+ <soap:address location="http://localhost:8080/RiftSaw_299_helloWS"/>
+ </wsdl:port>
+ <wsdl:port name="HelloCallbackPort" binding="tns:HelloCallbackSoapBinding">
+ <soap:address location="http://localhost:8080/RiftSaw_299_helloCallbackWS"/>
+ </wsdl:port>
+ </wsdl:service>
+
+ <plnk:partnerLinkType name="HelloPartnerLinkType">
+ <plnk:role name="me" portType="tns:HelloPortType"/>
+ <plnk:role name="you" portType="tns:HelloPortType"/>
+ </plnk:partnerLinkType>
+
+ <plnk:partnerLinkType name="HelloCallbackPartnerLinkType">
+ <plnk:role name="me" portType="tns:HelloCallbackPortType"/>
+ <plnk:role name="you" portType="tns:HelloCallbackPortType"/>
+ </plnk:partnerLinkType>
+
+ <vprop:property name="SessionID" type="xsd:int" />
+
+ <vprop:propertyAlias propertyName="tns:SessionID"
+ messageType="tns:HelloMessage" part="ID">
+ <vprop:query>id</vprop:query>
+ </vprop:propertyAlias>
+
+
+</wsdl:definitions>
+
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/deploy.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/deploy.xml (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/bpel/deploy.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,46 @@
+<!--
+ ~ 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.
+ -->
+<deploy xmlns="http://www.apache.org/ode/schemas/dd/2007/03"
+ xmlns:bpl="http://www.jboss.org/bpel/examples"
+ xmlns:intf="http://www.jboss.org/bpel/examples/wsdl"
+ xmlns:intf2="http://www.jboss.org/bpel/examples/wsdl2">
+
+ <process name="bpl:Hello">
+ <active>true</active>
+ <provide partnerLink="helloPartnerLink">
+ <service name="intf:HelloService" port="HelloPort"/>
+ </provide>
+ <provide partnerLink="helloCallbackPartnerLink">
+ <service name="intf:HelloService" port="HelloCallbackPort"/>
+ </provide>
+ <invoke partnerLink="goodbyePartnerLink" usePeer2Peer="false">
+ <service name="intf2:GoodbyeService" port="GoodbyePort" />
+ </invoke>
+ </process>
+
+ <process name="bpl:Goodbye">
+ <active>true</active>
+ <provide partnerLink="goodbyePartnerLink">
+ <service name="intf2:GoodbyeService" port="GoodbyePort"/>
+ </provide>
+ <invoke partnerLink="helloCallbackPartnerLink" usePeer2Peer="false" >
+ <service name="intf:HelloService" port="HelloCallbackPort" />
+ </invoke>
+ </process>
+</deploy>
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/build.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/build.xml (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/build.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,29 @@
+<project name="RiftSaw_299_ws" default="deploy" basedir=".">
+
+ <description>
+ ${ant.project.name}
+ ${line.separator}
+ </description>
+
+ <property name="version" value="1" />
+
+ <property name="deploy.dir" value="${basedir}/target/tests"/>
+ <property name="test.dir" value="${basedir}/src/test/resources/testcases/${ant.project.name}"/>
+
+ <property name="sample.jar.name" value="${ant.project.name}-${version}.jar" />
+
+ <target name="deploy">
+ <echo>Deploy ${ant.project.name}</echo>
+ <mkdir dir="${deploy.dir}/${ant.project.name}" />
+ <jar basedir="${test.dir}/bpel" destfile="${deploy.dir}/${ant.project.name}/${sample.jar.name}" />
+
+ <copy todir="${deploy.dir}/${ant.project.name}">
+ <fileset dir="${test.dir}/messages"/>
+ </copy>
+ </target>
+
+ <target name="undeploy">
+ <echo>Undeploy ${ant.project.name}</echo>
+ <delete file="${deploy.dir}/${sample.jar.name}" />
+ </target>
+</project>
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/hello_request1.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/hello_request1.xml (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/hello_request1.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,11 @@
+<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:wsdl="http://www.jboss.org/bpel/examples/wsdl">
+ <soapenv:Header/>
+ <soapenv:Body>
+ <wsdl:hello>
+ <ID>
+ <id>1</id>
+ </ID>
+ <Message>Hello</Message>
+ </wsdl:hello>
+ </soapenv:Body>
+</soapenv:Envelope>
\ No newline at end of file
Added: branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/hello_response1.xml
===================================================================
--- branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/hello_response1.xml (rev 0)
+++ branches/RiftSaw-2.1.x/integration-tests/src/test/resources/testcases/RiftSaw_299_ws/messages/hello_response1.xml 2010-10-12 16:49:52 UTC (rev 1035)
@@ -0,0 +1,3 @@
+<env:Envelope xmlns:env='http://schemas.xmlsoap.org/soap/envelope/'><env:Header></env:Header><env:Body><odens:helloResponse xmlns:odens='http://www.jboss.org/bpel/examples/wsdl'><ID>
+ <id>1</id>
+ </ID><Message>Hello World</Message></odens:helloResponse></env:Body></env:Envelope>
\ No newline at end of file
14 years, 11 months
- 1
- 0
riftsaw SVN: r1034 - in trunk: console/bpel2svg and 8 other directories.
by riftsaw-commits＠lists.jboss.org
Author: heiko.braun(a)jboss.com
Date: 2010-10-12 08:34:16 -0400 (Tue, 12 Oct 2010)
New Revision: 1034
Added:
trunk/console/integration/src/main/java/org/jboss/soa/bpel/console/SVGPlugin.java
trunk/console/integration/src/main/java/org/jboss/soa/bpel/console/util/LRUCache.java
trunk/console/integration/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.GraphViewerPlugin
Modified:
trunk/console/bpel2svg/pom.xml
trunk/console/bpel2svg/src/main/java/org/jboss/soa/bpel/bpel2svg/BPEL2SVGUtil.java
trunk/console/integration/pom.xml
trunk/distribution/pom.xml
trunk/distribution/src/main/assembly/bin.xml
trunk/distribution/src/main/release/install/build.xml
trunk/pom.xml
Log:
RIFTSAW-262: Implement graph viewer plugin
Modified: trunk/console/bpel2svg/pom.xml
===================================================================
--- trunk/console/bpel2svg/pom.xml 2010-10-12 05:23:49 UTC (rev 1033)
+++ trunk/console/bpel2svg/pom.xml 2010-10-12 12:34:16 UTC (rev 1034)
@@ -104,6 +104,11 @@
<artifactId>axiom-impl</artifactId>
<version>${axiom.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.ws.commons.axiom</groupId>
+ <artifactId>axiom-api</artifactId>
+ <version>${axiom.version}</version>
+ </dependency>
<dependency>
<groupId>xml-apis</groupId>
<artifactId>xml-apis-ext</artifactId>
Modified: trunk/console/bpel2svg/src/main/java/org/jboss/soa/bpel/bpel2svg/BPEL2SVGUtil.java
===================================================================
--- trunk/console/bpel2svg/src/main/java/org/jboss/soa/bpel/bpel2svg/BPEL2SVGUtil.java 2010-10-12 05:23:49 UTC (rev 1033)
+++ trunk/console/bpel2svg/src/main/java/org/jboss/soa/bpel/bpel2svg/BPEL2SVGUtil.java 2010-10-12 12:34:16 UTC (rev 1034)
@@ -141,6 +141,8 @@
LayoutManager layoutManager = BPEL2SVGFactory.getInstance().getLayoutManager();
layoutManager.setVerticalLayout(true);
+ layoutManager.setYSpacing(20);
+ layoutManager.setYSpacing(50);
layoutManager.layoutSVG(bpel.getRootActivity());
SVGImpl svg = new SVGImpl();
Modified: trunk/console/integration/pom.xml
===================================================================
--- trunk/console/integration/pom.xml 2010-10-12 05:23:49 UTC (rev 1033)
+++ trunk/console/integration/pom.xml 2010-10-12 12:34:16 UTC (rev 1034)
@@ -32,6 +32,12 @@
<!-- RiftSaw -->
<dependency>
+ <groupId>org.jboss.soa.bpel.console</groupId>
+ <artifactId>bpel2svg</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
<groupId>org.jboss.soa.bpel</groupId>
<artifactId>riftsaw-bpel-api</artifactId>
</dependency>
Added: trunk/console/integration/src/main/java/org/jboss/soa/bpel/console/SVGPlugin.java
===================================================================
--- trunk/console/integration/src/main/java/org/jboss/soa/bpel/console/SVGPlugin.java (rev 0)
+++ trunk/console/integration/src/main/java/org/jboss/soa/bpel/console/SVGPlugin.java 2010-10-12 12:34:16 UTC (rev 1034)
@@ -0,0 +1,165 @@
+/*
+ * Copyright 2009 JBoss, a divison Red Hat, Inc
+ *
+ * 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.
+ */
+package org.jboss.soa.bpel.console;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.ode.bpel.iapi.ProcessConf;
+import org.jboss.bpm.console.client.model.ActiveNodeInfo;
+import org.jboss.bpm.console.client.model.DiagramInfo;
+import org.jboss.bpm.console.server.plugin.GraphViewerPlugin;
+import org.jboss.soa.bpel.bpel2svg.BPEL2SVGUtil;
+import org.jboss.soa.bpel.console.util.LRUCache;
+import org.jboss.soa.bpel.runtime.engine.BPELEngine;
+import org.jboss.soa.bpel.runtime.engine.ode.BPELEngineImpl;
+import org.jboss.soa.bpel.runtime.integration.ServerConfig;
+import org.jboss.soa.bpel.runtime.integration.ServerConfigFactory;
+import org.wso2.carbon.bpel.ui.bpel2svg.SVGInterface;
+
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+import javax.xml.namespace.QName;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.InputStream;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Provides the BPEL process images to the console
+ * leveraging the {@link org.jboss.soa.bpel.bpel2svg.BPEL2SVGUtil}
+ *
+ * @author: Heiko Braun <hbraun(a)redhat.com>
+ * @date: Oct 12, 2010
+ */
+public class SVGPlugin implements GraphViewerPlugin {
+
+ protected final static Log log = LogFactory.getLog(SVGPlugin.class);
+
+ protected final static String WEB_CONTEXT = "/gwt-console-server/rs";
+
+ protected String webServiceHost = null;
+ protected int webServicePort = 8080;
+
+ private BPELEngine engine;
+
+ private LRUCache cache;
+
+ public SVGPlugin() {
+
+ // host & port resolution
+ ServerConfig serverConfig = ServerConfigFactory.getServerConfig();
+ this.webServiceHost = serverConfig.getWebServiceHost();
+ this.webServicePort = serverConfig.getWebServicePort();
+
+ try
+ {
+ InitialContext ctx = new InitialContext();
+ engine = (BPELEngine)ctx.lookup("bpel/Engine");
+ }
+ catch (NamingException e)
+ {
+ throw new RuntimeException("Failed to initialize BPEL engine");
+ }
+
+ cache = new LRUCache(20);
+ }
+
+ protected StringBuilder getBaseUrl() {
+ StringBuilder spec = new StringBuilder();
+ spec.append("http://");
+ spec.append(webServiceHost);
+ spec.append(":");
+ spec.append(webServicePort);
+ spec.append(WEB_CONTEXT);
+ return spec;
+ }
+
+ public byte[] getProcessImage(String processId) {
+
+ // any cache hits?
+ byte[] cached = (byte[])cache.get(processId);
+ if(cached !=null)
+ return cached;
+
+ // generate new
+ InputStream in = getBpelDescriptor(processId);
+
+ SVGInterface svg = null;
+
+ try {
+ svg = BPEL2SVGUtil.generate(in);
+
+ if (svg == null)
+ log.error("Failed to get SVGInterface");
+
+ } catch(Exception e) {
+ throw new RuntimeException("Failed to render process image", e);
+ }
+
+ byte[] bytes = svg.toPNGBytes();
+
+ cache.put(processId, bytes);
+
+ return bytes;
+ }
+
+ private InputStream getBpelDescriptor(String processId)
+ {
+ String actualId = ModelAdaptor.decodeId(processId);
+ QName qName= QName.valueOf(actualId);
+ ProcessConf pconf = ((BPELEngineImpl)engine)._store.getProcessConfiguration(qName);
+
+ try {
+ File deployDir = new File(pconf.getBaseURI());
+ File bpelDoc = new File(deployDir, pconf.getBpelDocument());
+ return new FileInputStream(bpelDoc);
+ } catch (FileNotFoundException e) {
+ throw new RuntimeException("Faile to load bpel file", e);
+ }
+ }
+
+ public DiagramInfo getDiagramInfo(String processId) {
+ throw new RuntimeException("Not implemented");
+ }
+
+ public List<ActiveNodeInfo> getActiveNodeInfo(String instanceId) {
+ return new ArrayList<ActiveNodeInfo>(); // Not used
+ }
+
+ public URL getDiagramURL(String id) {
+ URL result = null;
+
+ StringBuilder sb = getBaseUrl().append("/process/definition/");
+ sb.append(id);
+ sb.append("/image");
+
+ try {
+ result = new URL(sb.toString());
+ } catch (MalformedURLException e) {
+ throw new RuntimeException("Failed to create url", e);
+ }
+
+ return result;
+ }
+
+ public List<ActiveNodeInfo> getNodeInfoForActivities(String processDefinitionId, List<String> activities) {
+ return new ArrayList<ActiveNodeInfo>(); // Not used
+ }
+}
Added: trunk/console/integration/src/main/java/org/jboss/soa/bpel/console/util/LRUCache.java
===================================================================
--- trunk/console/integration/src/main/java/org/jboss/soa/bpel/console/util/LRUCache.java (rev 0)
+++ trunk/console/integration/src/main/java/org/jboss/soa/bpel/console/util/LRUCache.java 2010-10-12 12:34:16 UTC (rev 1034)
@@ -0,0 +1,96 @@
+/*
+ * Copyright 2009 JBoss, a divison Red Hat, Inc
+ *
+ * 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.
+ */
+package org.jboss.soa.bpel.console.util;
+
+import java.util.LinkedHashMap;
+import java.util.Collection;
+import java.util.Map;
+import java.util.ArrayList;
+
+/**
+ * An LRU cache, based on <code>LinkedHashMap</code>.<br>
+ * This cache has a fixed maximum number of elements (<code>cacheSize</code>).
+ * If the cache is full and another entry is added, the LRU (least recently used) entry is dropped.
+ * <p>
+ * This class is thread-safe. All methods of this class are synchronized.<br>
+ * Author: Christian d'Heureuse (<a href="http://www.source-code.biz">www.source-code.biz</a>)<br>
+ * License: <a href="http://www.gnu.org/licenses/lgpl.html">LGPL</a>.
+ */
+public class LRUCache<K,V> {
+
+ private static final float hashTableLoadFactor = 0.75f;
+
+ private LinkedHashMap<K,V> map;
+ private int cacheSize;
+
+ /**
+ * Creates a new LRU cache.
+ * @param cacheSize the maximum number of entries that will be kept in this cache.
+ */
+ public LRUCache (int cacheSize) {
+ this.cacheSize = cacheSize;
+ int hashTableCapacity = (int)Math.ceil(cacheSize / hashTableLoadFactor) + 1;
+ map = new LinkedHashMap<K,V>(hashTableCapacity, hashTableLoadFactor, true) {
+ // (an anonymous inner class)
+ private static final long serialVersionUID = 1;
+ @Override
+ protected boolean removeEldestEntry (Map.Entry<K,V> eldest) {
+ return size() > LRUCache.this.cacheSize;
+ }
+ };
+ }
+
+ /**
+ * Retrieves an entry from the cache.<br>
+ * The retrieved entry becomes the MRU (most recently used) entry.
+ * @param key the key whose associated value is to be returned.
+ * @return the value associated to this key, or null if no value with this key exists in the cache.
+ */
+ public synchronized V get (K key) {
+ return map.get(key); }
+
+ /**
+ * Adds an entry to this cache.
+ * The new entry becomes the MRU (most recently used) entry.
+ * If an entry with the specified key already exists in the cache, it is replaced by the new entry.
+ * If the cache is full, the LRU (least recently used) entry is removed from the cache.
+ * @param key the key with which the specified value is to be associated.
+ * @param value a value to be associated with the specified key.
+ */
+ public synchronized void put (K key, V value) {
+ map.put (key, value); }
+
+ /**
+ * Clears the cache.
+ */
+ public synchronized void clear() {
+ map.clear(); }
+
+ /**
+ * Returns the number of used entries in the cache.
+ * @return the number of entries currently in the cache.
+ */
+ public synchronized int usedEntries() {
+ return map.size(); }
+
+ /**
+ * Returns a <code>Collection</code> that contains a copy of all cache entries.
+ * @return a <code>Collection</code> with a copy of the cache content.
+ */
+ public synchronized Collection<Map.Entry<K,V>> getAll() {
+ return new ArrayList<Map.Entry<K,V>>(map.entrySet()); }
+
+} // end class LRUCache
\ No newline at end of file
Added: trunk/console/integration/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.GraphViewerPlugin
===================================================================
--- trunk/console/integration/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.GraphViewerPlugin (rev 0)
+++ trunk/console/integration/src/main/resources/META-INF/services/org.jboss.bpm.console.server.plugin.GraphViewerPlugin 2010-10-12 12:34:16 UTC (rev 1034)
@@ -0,0 +1 @@
+org.jboss.soa.bpel.console.SVGPlugin
\ No newline at end of file
Modified: trunk/distribution/pom.xml
===================================================================
--- trunk/distribution/pom.xml 2010-10-12 05:23:49 UTC (rev 1033)
+++ trunk/distribution/pom.xml 2010-10-12 12:34:16 UTC (rev 1034)
@@ -173,6 +173,12 @@
<dependency>
<groupId>org.jboss.soa.bpel.console</groupId>
+ <artifactId>bpel2svg</artifactId>
+ <version>${version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.jboss.soa.bpel.console</groupId>
<artifactId>integration</artifactId>
<version>${version}</version>
</dependency>
Modified: trunk/distribution/src/main/assembly/bin.xml
===================================================================
--- trunk/distribution/src/main/assembly/bin.xml 2010-10-12 05:23:49 UTC (rev 1033)
+++ trunk/distribution/src/main/assembly/bin.xml 2010-10-12 12:34:16 UTC (rev 1034)
@@ -19,196 +19,224 @@
* (C) 2008
-->
<assembly>
- <!-- id typically identifies the "type" (src vs bin etc) of the assembly -->
- <id></id>
- <includeBaseDirectory>true</includeBaseDirectory>
- <formats>
- <format>zip</format>
- </formats>
+ <!-- id typically identifies the "type" (src vs bin etc) of the assembly -->
+ <id></id>
+ <includeBaseDirectory>true</includeBaseDirectory>
+ <formats>
+ <format>zip</format>
+ </formats>
- <fileSets>
+ <fileSets>
- <!--Copy files like License and samples etc -->
- <fileSet>
- <directory>src/main/release</directory>
- <outputDirectory>/</outputDirectory>
- <includes>
- <include>*.txt</include>
- </includes>
- </fileSet>
+ <!--Copy files like License and samples etc -->
+ <fileSet>
+ <directory>src/main/release</directory>
+ <outputDirectory>/</outputDirectory>
+ <includes>
+ <include>*.txt</include>
+ </includes>
+ </fileSet>
- <fileSet>
- <directory>src/main/release/install</directory>
- <outputDirectory>/install</outputDirectory>
- </fileSet>
+ <fileSet>
+ <directory>src/main/release/install</directory>
+ <outputDirectory>/install</outputDirectory>
+ </fileSet>
- <fileSet>
- <directory>src/main/release/db</directory>
- <outputDirectory>/db</outputDirectory>
- </fileSet>
+ <fileSet>
+ <directory>src/main/release/db</directory>
+ <outputDirectory>/db</outputDirectory>
+ </fileSet>
- <fileSet>
- <directory>src/main/release/modules</directory>
- <outputDirectory>/modules</outputDirectory>
- </fileSet>
+ <fileSet>
+ <directory>src/main/release/modules</directory>
+ <outputDirectory>/modules</outputDirectory>
+ </fileSet>
- <fileSet>
- <directory>../runtime/deployer/target</directory>
- <outputDirectory>/modules/riftsaw.deployer</outputDirectory>
- <includes>
- <include>jboss-riftsaw-deployer.jar</include>
- </includes>
- </fileSet>
+ <fileSet>
+ <directory>../runtime/deployer/target</directory>
+ <outputDirectory>/modules/riftsaw.deployer</outputDirectory>
+ <includes>
+ <include>jboss-riftsaw-deployer.jar</include>
+ </includes>
+ </fileSet>
- <fileSet>
- <directory>../samples</directory>
- <outputDirectory>samples</outputDirectory>
- <includes>
- <include>common/**</include>
- <include>esb/bpel_helloworld/**</include>
- <include>esb/bpel_loan_fault/**</include>
- <include>esb/invoke_esb_ebws/**</include>
- <include>esb/simple_esb_proxy_invoke/**</include>
- <include>esb/simple_esb_proxy_invoke2/**</include>
- <include>quickstart/bpel_event_listener/**</include>
- <include>quickstart/fault_compensation/**</include>
- <include>quickstart/hello_world/**</include>
- <include>quickstart/hello_world_header_ode/**</include>
- <include>quickstart/hello_world_header_wsdl/**</include>
- <include>quickstart/loan_approval/**</include>
- <include>quickstart/math/**</include>
- <include>quickstart/salutations/**</include>
- <include>quickstart/say_hello/**</include>
- <include>quickstart/secure_invoke/**</include>
- <include>quickstart/secure_service/**</include>
- <include>quickstart/service_handler/**</include>
- <include>quickstart/simple_correlation/**</include>
- <include>quickstart/simple_invoke/**</include>
- <include>quickstart/simple_pick/**</include>
- <include>quickstart/while_wait/**</include>
- <include>tutorial/BPEL-BluePrint1/**</include>
- <include>tutorial/BPEL-BluePrint2/**</include>
- <include>tutorial/BPEL-BluePrint3/**</include>
- <include>tutorial/BPEL-BluePrint4/**</include>
- <include>tutorial/BPEL-BluePrint5/**</include>
- <include>readme.txt</include>
- </includes>
- </fileSet>
+ <fileSet>
+ <directory>../samples</directory>
+ <outputDirectory>samples</outputDirectory>
+ <includes>
+ <include>common/**</include>
+ <include>esb/bpel_helloworld/**</include>
+ <include>esb/bpel_loan_fault/**</include>
+ <include>esb/invoke_esb_ebws/**</include>
+ <include>esb/simple_esb_proxy_invoke/**</include>
+ <include>esb/simple_esb_proxy_invoke2/**</include>
+ <include>quickstart/bpel_event_listener/**</include>
+ <include>quickstart/fault_compensation/**</include>
+ <include>quickstart/hello_world/**</include>
+ <include>quickstart/hello_world_header_ode/**</include>
+ <include>quickstart/hello_world_header_wsdl/**</include>
+ <include>quickstart/loan_approval/**</include>
+ <include>quickstart/math/**</include>
+ <include>quickstart/salutations/**</include>
+ <include>quickstart/say_hello/**</include>
+ <include>quickstart/secure_invoke/**</include>
+ <include>quickstart/secure_service/**</include>
+ <include>quickstart/service_handler/**</include>
+ <include>quickstart/simple_correlation/**</include>
+ <include>quickstart/simple_invoke/**</include>
+ <include>quickstart/simple_pick/**</include>
+ <include>quickstart/while_wait/**</include>
+ <include>tutorial/BPEL-BluePrint1/**</include>
+ <include>tutorial/BPEL-BluePrint2/**</include>
+ <include>tutorial/BPEL-BluePrint3/**</include>
+ <include>tutorial/BPEL-BluePrint4/**</include>
+ <include>tutorial/BPEL-BluePrint5/**</include>
+ <include>readme.txt</include>
+ </includes>
+ </fileSet>
- <fileSet>
- <directory>src/main/release/bin</directory>
- <outputDirectory>bin</outputDirectory>
- <fileMode>755</fileMode>
- </fileSet>
+ <fileSet>
+ <directory>src/main/release/bin</directory>
+ <outputDirectory>bin</outputDirectory>
+ <fileMode>755</fileMode>
+ </fileSet>
- <fileSet>
- <directory>../docs/docbook/gettingstartedguide/target/docbook/publish/en-US</directory>
- <outputDirectory>docs/gettingstartedguide</outputDirectory>
- </fileSet>
+ <fileSet>
+ <directory>../docs/docbook/gettingstartedguide/target/docbook/publish/en-US</directory>
+ <outputDirectory>docs/gettingstartedguide</outputDirectory>
+ </fileSet>
- <fileSet>
- <directory>../docs/docbook/userguide/target/docbook/publish/en-US</directory>
- <outputDirectory>docs/userguide</outputDirectory>
- </fileSet>
+ <fileSet>
+ <directory>../docs/docbook/userguide/target/docbook/publish/en-US</directory>
+ <outputDirectory>docs/userguide</outputDirectory>
+ </fileSet>
- <fileSet>
- <directory>../console/integration/target</directory>
- <outputDirectory>/modules/bpel-console</outputDirectory>
- <includes>
- <include>riftsaw-console-integration.jar</include>
- </includes>
- </fileSet>
+ <fileSet>
+ <directory>../console/integration/target</directory>
+ <outputDirectory>/modules/bpel-console</outputDirectory>
+ <includes>
+ <include>riftsaw-console-integration.jar</include>
+ </includes>
+ </fileSet>
- <fileSet>
- <directory>../console/bpaf/target</directory>
- <outputDirectory>/modules/bpel-console</outputDirectory>
- <includes>
- <include>riftsaw-console-bpaf.jar</include>
- </includes>
- </fileSet>
+ <fileSet>
+ <directory>../console/bpaf/target</directory>
+ <outputDirectory>/modules/bpel-console</outputDirectory>
+ <includes>
+ <include>riftsaw-console-bpaf.jar</include>
+ </includes>
+ </fileSet>
- <fileSet>
- <directory>../console/identity/target</directory>
- <outputDirectory>/modules/bpel-console</outputDirectory>
- <includes>
- <include>riftsaw-console-identity.jar</include>
- </includes>
- </fileSet>
+ <fileSet>
+ <directory>../console/identity/target</directory>
+ <outputDirectory>/modules/bpel-console</outputDirectory>
+ <includes>
+ <include>riftsaw-console-identity.jar</include>
+ </includes>
+ </fileSet>
- <fileSet>
- <directory>../runtime/clustering/src/main/resources/</directory>
- <outputDirectory>/modules/clustering</outputDirectory>
- </fileSet>
+ <fileSet>
+ <directory>../runtime/clustering/src/main/resources/</directory>
+ <outputDirectory>/modules/clustering</outputDirectory>
+ </fileSet>
- </fileSets>
+ </fileSets>
- <dependencySets>
-
- <dependencySet>
- <outputDirectory>/modules</outputDirectory>
- <unpack>true</unpack>
- <includes>
- <include>org.jboss.soa.bpel.runtime:bpel.esb:zip</include>
- </includes>
- </dependencySet>
-
- <dependencySet>
- <outputDirectory>/modules/riftsaw.sar</outputDirectory>
- <unpack>true</unpack>
- <includes>
- <include>org.jboss.soa.bpel.runtime:riftsaw:zip</include>
- </includes>
- </dependencySet>
+ <dependencySets>
- <dependencySet>
- <outputDirectory>/db/drivers</outputDirectory>
- <includes>
- <include>net.sourceforge.jtds:jtds</include>
- <include>postgresql:postgresql</include>
- <include>mysql:mysql-connector-java</include>
- <include>org.apache.derby:derby</include>
- <include>org.apache.derby:derbytools</include>
- <include>com.h2database:h2</include>
- </includes>
- </dependencySet>
+ <dependencySet>
+ <outputDirectory>/modules</outputDirectory>
+ <unpack>true</unpack>
+ <includes>
+ <include>org.jboss.soa.bpel.runtime:bpel.esb:zip</include>
+ </includes>
+ </dependencySet>
- <dependencySet>
- <outputDirectory>/modules/bpel-console</outputDirectory>
- <outputFileNameMapping>${artifact.artifactId}.${artifact.extension}</outputFileNameMapping>
- <includes>
- <include>org.jboss.bpm:gwt-console</include>
- <include>org.jboss.bpm:gwt-console-server</include>
- <include>org.jboss.bpm:gwt-console-server-integration</include>
- <include>org.jboss.bpm:gwt-console-rpc</include>
- <include>org.codehaus.jettison:jettison</include>
- <include>org.jboss.bpm:activity-monitor-model</include>
- </includes>
- </dependencySet>
-
- <dependencySet>
- <outputDirectory>/lib</outputDirectory>
- <includes>
- <include>commons-codec:commons-codec</include>
- <include>commons-httpclient:commons-httpclient</include>
- <include>org.jboss.soa.bpel:riftsaw-tools</include>
- </includes>
- </dependencySet>
+ <dependencySet>
+ <outputDirectory>/modules/riftsaw.sar</outputDirectory>
+ <unpack>true</unpack>
+ <includes>
+ <include>org.jboss.soa.bpel.runtime:riftsaw:zip</include>
+ </includes>
+ </dependencySet>
- <!-- clustering module -->
- <dependencySet>
- <outputDirectory>/modules/clustering</outputDirectory>
- <includes>
- <include>org.jboss.soa.bpel.runtime:riftsaw-clustering</include>
- </includes>
- </dependencySet>
+ <dependencySet>
+ <outputDirectory>/db/drivers</outputDirectory>
+ <includes>
+ <include>net.sourceforge.jtds:jtds</include>
+ <include>postgresql:postgresql</include>
+ <include>mysql:mysql-connector-java</include>
+ <include>org.apache.derby:derby</include>
+ <include>org.apache.derby:derbytools</include>
+ <include>com.h2database:h2</include>
+ </includes>
+ </dependencySet>
- <!-- juddi-client, should be removed once esb catches up to 3.0.4-->
- <dependencySet>
- <outputDirectory>/db/juddi</outputDirectory>
- <includes>
- <include>org.apache.juddi:juddi-client</include>
- </includes>
- </dependencySet>
- </dependencySets>
+ <dependencySet>
+ <outputDirectory>/modules/bpel-console</outputDirectory>
+ <outputFileNameMapping>${artifact.artifactId}.${artifact.extension}</outputFileNameMapping>
+ <includes>
+ <include>org.jboss.bpm:gwt-console</include>
+ <include>org.jboss.bpm:gwt-console-server</include>
+ <include>org.jboss.bpm:gwt-console-server-integration</include>
+ <include>org.jboss.bpm:gwt-console-rpc</include>
+ <include>org.codehaus.jettison:jettison</include>
+ <include>org.jboss.bpm:activity-monitor-model</include>
+ </includes>
+ </dependencySet>
+ <dependencySet>
+ <outputDirectory>/modules/bpel-console/bpel2svg</outputDirectory>
+ <outputFileNameMapping>${artifact.artifactId}.${artifact.extension}</outputFileNameMapping>
+ <includes>
+ <include>org.jboss.soa.bpel.console:bpel2svg</include>
+ <include>batik:batik-anim</include>
+ <include>batik:batik-awt-util</include>
+ <include>batik:batik-bridge</include>
+ <include>batik:batik-codec</include>
+ <include>batik:batik-css</include>
+ <include>batik:batik-dom</include>
+ <include>batik:batik-ext</include>
+ <include>batik:batik-gvt</include>
+ <include>batik:batik-parser</include>
+ <include>batik:batik-script</include>
+ <include>batik:batik-svg-dom</include>
+ <include>batik:batik-svggen</include>
+ <include>batik:batik-transcoder</include>
+ <include>batik:batik-util</include>
+ <include>batik:batik-xml</include>
+ <include>org.apache.ws.commons.axiom:axiom-impl</include>
+ <include>org.apache.ws.commons.axiom:axiom-api</include>
+ <include>commons-codec:commons-codec</include>
+ <include>xml-apis:xml-apis-ext</include>
+ </includes>
+ </dependencySet>
+
+
+ <dependencySet>
+ <outputDirectory>/lib</outputDirectory>
+ <includes>
+ <include>commons-codec:commons-codec</include>
+ <include>commons-httpclient:commons-httpclient</include>
+ <include>org.jboss.soa.bpel:riftsaw-tools</include>
+ </includes>
+ </dependencySet>
+
+ <!-- clustering module -->
+ <dependencySet>
+ <outputDirectory>/modules/clustering</outputDirectory>
+ <includes>
+ <include>org.jboss.soa.bpel.runtime:riftsaw-clustering</include>
+ </includes>
+ </dependencySet>
+
+ <!-- juddi-client, should be removed once esb catches up to 3.0.4-->
+ <dependencySet>
+ <outputDirectory>/db/juddi</outputDirectory>
+ <includes>
+ <include>org.apache.juddi:juddi-client</include>
+ </includes>
+ </dependencySet>
+ </dependencySets>
+
</assembly>
Modified: trunk/distribution/src/main/release/install/build.xml
===================================================================
--- trunk/distribution/src/main/release/install/build.xml 2010-10-12 05:23:49 UTC (rev 1033)
+++ trunk/distribution/src/main/release/install/build.xml 2010-10-12 12:34:16 UTC (rev 1034)
@@ -103,6 +103,10 @@
<mkdir dir="${deploy.dir}/bpel-console/bpel-identity.sar"/>
<mkdir dir="${deploy.dir}/bpel-console/gwt-console-server.war"/>
+ <copy todir="${deploy.dir}/bpel-console/bpel2svg">
+ <fileset dir="${modules}/bpel-console/bpel2svg"/>
+ </copy>
+
<copy file="${modules}/bpel-console/riftsaw-console-bpaf.jar" todir="${deploy.dir}/bpel-console"/>
<copy file="${modules}/bpel-console/activity-monitor-model.jar" todir="${deploy.dir}/bpel-console"/>
Modified: trunk/pom.xml
===================================================================
--- trunk/pom.xml 2010-10-12 05:23:49 UTC (rev 1033)
+++ trunk/pom.xml 2010-10-12 12:34:16 UTC (rev 1034)
@@ -77,7 +77,7 @@
<properties>
<riftsaw.ode.version>2.2.0-SNAPSHOT</riftsaw.ode.version>
<riftsaw.engine.version>2.2.0-SNAPSHOT</riftsaw.engine.version>
- <bpel.console.version>2.1.2</bpel.console.version>
+ <bpel.console.version>2.2.0-SNAPSHOT</bpel.console.version>
<activity.monitor.model.version>1.0.0-Beta1</activity.monitor.model.version>
<commons.logging.version>1.1.1</commons.logging.version>
<junit.version>4.8.1</junit.version>
14 years, 12 months
- 1
- 0
riftsaw SVN: r1033 - branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws.
by riftsaw-commits＠lists.jboss.org
Author: jeff.yuchang
Date: 2010-10-12 01:23:49 -0400 (Tue, 12 Oct 2010)
New Revision: 1033
Modified:
branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java
Log:
*RIFTSAW-299, defer the invocation util transaction commits.
Modified: branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java
===================================================================
--- branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java 2010-10-11 13:20:23 UTC (rev 1032)
+++ branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java 2010-10-12 05:23:49 UTC (rev 1033)
@@ -189,11 +189,24 @@
}
else
{
- // one-way invocation
- ExecutorService executorService = executionEnvironment.getExecutorService();
+ // one-way invocation, also defer the invoke until the transaction commits.
+ Scheduler scheduler = executionEnvironment.getScheduler();
executionCallable = new OneWayCallable(mex.getMessageExchangeId());
- executorService.submit(executionCallable);
-
+
+ scheduler.registerSynchronizer(new Scheduler.Synchronizer() {
+
+ public void beforeCompletion() {
+
+ }
+
+ public void afterCompletion(boolean success) {
+ if (!success) return;
+
+ ExecutorService executorService = executionEnvironment.getExecutorService();
+ executorService.submit(executionCallable);
+ }
+ });
+
mex.replyOneWayOk();
}
}
14 years, 12 months
- 1
- 0
Hudson build became unstable: RiftSaw-db2-2.1.x #10
by jboss-qa-internal＠redhat.com
See <http://hudson.qa.jboss.com/hudson/job/RiftSaw-db2-2.1.x/10/changes>
14 years, 12 months
- 1
- 1
riftsaw SVN: r1032 - branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws.
by riftsaw-commits＠lists.jboss.org
Author: jeff.yuchang
Date: 2010-10-11 09:20:23 -0400 (Mon, 11 Oct 2010)
New Revision: 1032
Modified:
branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java
Log:
* RIFTSAW-299, fix the 'self-assign' mistake.
Modified: branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java
===================================================================
--- branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java 2010-10-07 09:57:19 UTC (rev 1031)
+++ branches/RiftSaw-2.1.x/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java 2010-10-11 13:20:23 UTC (rev 1032)
@@ -303,7 +303,7 @@
private String mexId;
- public OneWayCallable(String mex) {
+ public OneWayCallable(String mexId) {
this.mexId = mexId;
}
14 years, 12 months
- 1
- 0
Hudson build became unstable: RiftSaw-jbossws-cxf-2.1.x #54
by jboss-qa-internal＠redhat.com
See <http://hudson.qa.jboss.com/hudson/job/RiftSaw-jbossws-cxf-2.1.x/54/changes>
14 years, 12 months
- 1
- 2
RiftSaw - Build # 275 - Failure!
by jboss-qa-internal＠redhat.com
RiftSaw Build number 275 status: Failure
Details available at http://hudson.jboss.org/hudson/job/RiftSaw/275/
JBoss server log can be found at workspace, http://hudson.qa.jboss.com/hudson/view/RiftSaw/job/RiftSaw/ws/
14 years, 12 months
- 1
- 0