Moving 1.x trunk

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@835700 13f79535-47bb-0310-9956-ffa450edef68

6 files changed, 471 insertions, 0 deletions

diff --git a/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/pom.xml b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/pom.xml
new file mode 100644
index 0000000000..4a8ec3ac26
--- /dev/null
+++ b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/pom.xml
@@ -0,0 +1,104 @@
+<?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.    
+-->
+<project>
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.apache.tuscany.sca</groupId>
+        <artifactId>itest-domainmgr-transaction</artifactId>
+        <version>1.6-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+    <artifactId>itest-domainmgr-transaction-runtest</artifactId>
+    <name>Apache Tuscany SCA iTest Domain Manager Transaction Run Test</name>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.tuscany.sca</groupId>
+            <artifactId>itest-domainmgr-transaction-payment</artifactId>
+            <version>1.6-SNAPSHOT</version>
+            <scope>provided</scope>
+        </dependency>
+        
+        <dependency>
+            <groupId>org.apache.tuscany.sca</groupId>
+            <artifactId>tuscany-implementation-java-runtime</artifactId>
+            <version>1.6-SNAPSHOT</version>
+            <scope>runtime</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.tuscany.sca</groupId>
+            <artifactId>tuscany-binding-ws-axis2</artifactId>
+            <version>1.6-SNAPSHOT</version>
+            <scope>runtime</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.tuscany.sca</groupId>
+            <artifactId>tuscany-policy-security</artifactId>
+            <version>1.6-SNAPSHOT</version>
+            <scope>runtime</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.tuscany.sca</groupId>
+            <artifactId>tuscany-policy-transaction</artifactId>
+            <version>1.6-SNAPSHOT</version>
+            <scope>runtime</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.tuscany.sca</groupId>
+            <artifactId>tuscany-domain-manager</artifactId>
+            <version>1.6-SNAPSHOT</version>
+            <scope>test</scope>
+        </dependency> 
+        
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.5</version>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <finalName>${artifactId}</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <version>2.3.1</version>
+                <configuration>
+                    <includes>
+                        <include>**/*TestCase.java</include>
+                    </includes>
+                    <reportFormat>brief</reportFormat>
+                    <useFile>false</useFile>
+                    <forkMode>once</forkMode>
+                    <argLine>-ea -Xmx256m</argLine>
+                    <useSystemClassLoader>true</useSystemClassLoader>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+    
+</project>
diff --git a/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/java/domainmgr/DomainManagerTransactionTestCase.java b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/java/domainmgr/DomainManagerTransactionTestCase.java
new file mode 100644
index 0000000000..ef99628686
--- /dev/null
+++ b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/java/domainmgr/DomainManagerTransactionTestCase.java
@@ -0,0 +1,328 @@
+/*

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you under the Apache License, Version 2.0 (the

+ * "License"); you may not use this file except in compliance

+ * with the License.  You may obtain a copy of the License at

+ * 

+ *   http://www.apache.org/licenses/LICENSE-2.0

+ * 

+ * Unless required by applicable law or agreed to in writing,

+ * software distributed under the License is distributed on an

+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+ * KIND, either express or implied.  See the License for the

+ * specific language governing permissions and limitations

+ * under the License.    

+ */

+package domainmgr;

+

+import java.io.BufferedReader;

+import java.io.File;

+import java.io.InputStream;

+import java.io.InputStreamReader;

+import java.io.OutputStream;

+

+import org.junit.Test;

+

+/**

+ * Starts the Romain Manager with a test configuration, then starts

+ * a test node that reads a deployed composite.  The domain manager

+ * should read and configure the composite and send it to the node

+ * without detecting or reporting any errors.

+ */

+public class DomainManagerTransactionTestCase {

+

+    private String home = System.getProperty("java.home");

+    private String classpath = System.getProperty("java.class.path");

+    private Runtime runtime = Runtime.getRuntime();

+    private Process domainMgr = null;

+    private BufferedReader domainErrReader;

+    private BufferedReader domainOutReader;

+    private OutputStream domainIn;

+

+    @Test

+    public void test() throws Exception {

+

+        TestNode paymentNode = null;

+

+        try {

+            // Start the domain manager process in its own working directory of

+            // "target/test-classes/domain/" to ensure no interference with the

+            // node processes.  The predefined domain config is copied by mvn

+            // from the "src/test/resources/domain/" directory.

+            System.out.println("Starting domain manager");

+            String[] domainCommand = {

+                "" + home + "/bin/java",

+                "-cp",

+                "" + classpath + "",

+                "org.apache.tuscany.sca.node.launcher.DomainManagerLauncher"};

+            String userdir = System.getProperty("user.dir");

+            domainMgr = runtime.exec(domainCommand, null, new File(userdir + "/target/test-classes/domain/"));

+

+            // Get the new process's stdin, stdout and stderr streams so that we

+            // can monitor and control execution of the domain manager process.

+            InputStream domainErr = domainMgr.getErrorStream();

+            domainErrReader = new BufferedReader(new InputStreamReader(domainErr));

+            InputStream domainOut = domainMgr.getInputStream();

+            domainOutReader = new BufferedReader(new InputStreamReader(domainOut));

+            domainIn = domainMgr.getOutputStream();

+

+            // Read startup log output from the domain manager process.  The log

+            // output is written to the process's stderr.

+            while (true) {

+                checkDomainOut();

+                String line = domainErrReader.readLine();

+                if (line == null) {

+                    // reached end of stderr stream before startup completed

+                    throw new IllegalStateException("Error starting Domain Manager process");

+                }

+                System.out.println("DomainMgr.e: " + line);

+                if (line.contains("SEVERE:")) {

+                    // startup error logged by domain manager process

+                    throw new IllegalStateException("Domain manager reported error: " + line);

+                }

+                if (line.contains("INFO: Press 'q' to quit, 'r' to restart.")) {

+                    // domain manager started successfully

+                    System.out.println("Domain manager started successfully");

+                    break;

+                }

+            }

+            checkDomainOut();

+            

+            // Start the test nodes.  Each node runs in its own "target" directory

+            // to ensure no interference with other processes.

+            paymentNode = new TestNode("PaymentNode", userdir + "/../payment/target/");

+            paymentNode.start();

+

+            // Stop the test nodes.

+            paymentNode.stopNode();

+

+            // Stop the domain manager

+            stopDomain();

+

+        } catch (Exception ex) {

+

+            // Error found, so destroy the test node processes and the domain

+            // manager process so that the test case exits cleanly.

+            if (paymentNode != null) {

+                paymentNode.destroyNode();

+            }

+            if (domainMgr != null) {

+                System.out.println("Destroying domain");

+                try {

+                    domainMgr.destroy();

+                } catch (Exception e) {

+                }

+            }

+

+            // Report the test error.

+            throw ex;

+        }

+    }

+

+    /*

+     * Stop the test node process.

+     */

+     void stopDomain() throws Exception {

+

+        // Stop the domain manager by sending 'q' to stdin.

+        System.out.println("Stopping domain manager");

+        domainIn.write('q');

+        domainIn.flush();

+        while (true) {

+            checkDomainOut();

+            String line = domainErrReader.readLine();

+            if (line == null) {

+                // reached end of stderr stream before shutdown completed

+                throw new IllegalStateException("Error stopping Domain Manager process");

+            }

+            System.out.println("DomainMgr.e: " + line);

+            if (line.contains("SEVERE:")) {

+                // shutdown error logged by domain manager process

+                throw new IllegalStateException("Domain manager reported error: " + line);

+            }

+            if (line.contains("INFO: SCA Domain Manager is now stopped.")) {

+                // domain manager stopped successfully

+                System.out.println("Domain manager stopped successfully");

+                break;

+            }

+        }

+        checkDomainOut();

+

+        // Wait for domain manager process to end, and check its exit value.

+        int value = domainMgr.waitFor();

+        if (value != 0) {

+            throw new IllegalStateException("Domain Manager process exit value " + value);

+        }

+        domainMgr = null;

+    }

+

+    /*

+     * Check stderr for the domain manager process.  Called periodically

+     * to ensure that anything written to stderr is displayed in the test log

+     * and abort execution if the domain manager has logged any errors.

+     */

+    private void checkDomainErr() throws Exception {

+        while (domainErrReader.ready()) {

+            String line = domainErrReader.readLine();

+            System.out.println("DomainMgr.e: " + line);

+            if (line.contains("SEVERE:")) {

+                throw new IllegalStateException("Domain manager reported error: " + line);

+            }

+        }

+    }

+

+    /*

+     * Check stdout for the domain manager process.  Called periodically

+     * to ensure that anything written to stdout is displayed in the test log. 

+     */

+    private void checkDomainOut() throws Exception {

+        while (domainOutReader.ready()) {

+            String line = domainOutReader.readLine();

+            System.out.println("DomainMgr.o: " + line);

+        }

+    }

+

+    /*

+     * Internal class representing a test node.

+     */

+    private class TestNode {

+

+        String nodeName;

+        String nodeDir;

+        BufferedReader nodeErrReader;

+        BufferedReader nodeOutReader;

+        OutputStream nodeIn;

+        Process nodeProcess;

+

+        TestNode(String nodeName, String nodeDir) {

+            this.nodeName = nodeName;

+            this.nodeDir = nodeDir;

+        }

+

+        /*

+         * Start the test node.

+         */

+        void start() throws Exception {

+            System.out.println("Starting node " + nodeName);

+            String[] nodeCommand = {

+                "" + home + "/bin/java",

+                "-cp",

+                "" + classpath + "",

+                "org.apache.tuscany.sca.node.launcher.NodeLauncher",

+                "http://localhost:9990/node-config/" + nodeName};

+            nodeProcess = runtime.exec(nodeCommand, null, new File(nodeDir));

+

+            // Get the new process's stdin, stdout and stderr streams so that we

+            // can monitor and control execution of the test node process.

+            InputStream nodeErr = nodeProcess.getErrorStream();

+            nodeErrReader = new BufferedReader(new InputStreamReader(nodeErr));

+            InputStream nodeOut = nodeProcess.getInputStream();

+            nodeOutReader = new BufferedReader(new InputStreamReader(nodeOut));

+            nodeIn = nodeProcess.getOutputStream();

+

+            // Read startup log output from the test node process.  The log

+            // output is written to the process's stderr.

+            try {

+                while (true) {

+                    checkNodeOut();

+                    String line = nodeErrReader.readLine();

+                    if (line == null) {

+                        // reached end of stderr stream before startup completed

+                        throw new IllegalStateException("Error starting node " + nodeName);

+                    }

+                    System.out.println(nodeName + ".e: " + line);

+                    if (line.contains("SEVERE:")) {

+                        // startup error logged by test node process

+                        throw new IllegalStateException("Node " + nodeName + " reported error: " + line);

+                    }

+                    if (line.contains("INFO: Press 'q' to quit, 'r' to restart.")) {

+                        // test node started successfully

+                        System.out.println("Node " + nodeName + " started successfully");

+                        return;

+                    }

+                }

+            } finally {

+                checkDomainErr();

+                checkDomainOut();

+                checkNodeOut();

+            }

+        }

+

+        /*

+         * Check stderr for the test node process.  Called periodically to

+         * ensure that anything written to stderr is displayed in the test log

+         * and abort execution if the test node has logged any errors.

+         */

+        void checkNodeErr() throws Exception {

+            while (nodeErrReader.ready()) {

+                String line = nodeErrReader.readLine();

+                System.out.println(nodeName + ".e: " + line);

+                if (line.contains("SEVERE:")) {

+                    throw new IllegalStateException("Node " + nodeName + " reported error: " + line);

+                }

+            }

+        }

+

+        /*

+         * Check stdout for the test node process.  Called periodically to

+         * ensure that anything written to stdout is displayed in the test log.

+         */

+        void checkNodeOut() throws Exception {

+            while (nodeOutReader.ready()) {

+                String line = nodeOutReader.readLine();

+                System.out.println(nodeName + ".o: " + line);

+            }

+        }

+

+        /*

+         * Stop the test node process.

+         */

+        void stopNode() throws Exception {

+            System.out.println("Stopping node " + nodeName);

+            nodeIn.write('q');

+            nodeIn.flush();

+            while (true) {

+                checkNodeOut();

+                String line = nodeErrReader.readLine();

+                if (line == null) {

+                    // reached end of stderr stream before shutdown completed

+                    throw new IllegalStateException("Error stopping node " + nodeName);

+                }

+                System.out.println(nodeName + ".e: " + line);

+                if (line.contains("SEVERE:")) {

+                    // shutdown error logged by test node process

+                    throw new IllegalStateException("Node " + nodeName + " reported error: " + line);

+                }

+                if (line.contains("INFO: SCA Node is now stopped.")) {

+                    // test node stopped successfully

+                    System.out.println("Node " + nodeName + " stopped successfully");

+                    break;

+                }

+            }

+            checkNodeOut();

+

+            // Wait for test node process to end, and check its exit value.

+            int value = nodeProcess.waitFor();

+            if (value != 0) {

+                throw new IllegalStateException("Node " + nodeName + " exit value " + value);

+            }

+        }

+

+        /*

+         * Destroy the test node process.

+         */

+        void destroyNode() {

+            if (nodeProcess != null) {

+                System.out.println("Destroying node " + nodeName);

+                try {

+                    nodeProcess.destroy();

+                } catch (Exception e) {

+                }

+            }

+        }

+    }

+

+}

diff --git a/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/cloud.composite b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/cloud.composite
new file mode 100644
index 0000000000..ca43648169
--- /dev/null
+++ b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/cloud.composite
@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<composite local="true" name="cloud"
+           targetNamespace="http://tuscany.apache.org/xmlns/sca/1.0"
+           xmlns="http://www.osoa.org/xmlns/sca/1.0"
+           xmlns:ns1="http://www.osoa.org/xmlns/sca/1.0">
+    <include name="ns2:PaymentNode"
+           uri="http://tuscany.apache.org/cloud"
+           xmlns:ns2="http://tuscany.apache.org/cloud" />
+</composite>
diff --git a/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/cloud/PaymentNode.composite b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/cloud/PaymentNode.composite
new file mode 100644
index 0000000000..e61fd4c1a3
--- /dev/null
+++ b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/cloud/PaymentNode.composite
@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
+           xmlns:t="http://tuscany.apache.org/xmlns/sca/1.0"
+           xmlns:c="http://scatours"
+           targetNamespace="http://tuscany.apache.org/cloud"
+           name="PaymentNode">
+    <component name="PaymentNode">
+        <t:implementation.node uri="scatours-payment" composite="c:payment" />
+        <service name="Node">
+             <binding.ws uri="http://localhost:8081" />
+        </service>
+    </component>
+</composite>
diff --git a/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/domain.composite b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/domain.composite
new file mode 100644
index 0000000000..f03181ecc5
--- /dev/null
+++ b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/domain.composite
@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<composite local="true" name="domain"
+           targetNamespace="http://tuscany.apache.org/xmlns/sca/1.0"
+           xmlns="http://www.osoa.org/xmlns/sca/1.0"
+           xmlns:ns1="http://www.osoa.org/xmlns/sca/1.0">
+    <include name="ns2:payment"
+           uri="scatours-payment"
+           xmlns:ns2="http://scatours" />
+</composite>
diff --git a/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/workspace.xml b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/workspace.xml
new file mode 100644
index 0000000000..1379b37dce
--- /dev/null
+++ b/sca-java-1.x/trunk/itest/domainmgr/transaction/runtest/src/test/resources/domain/workspace.xml
@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<workspace xmlns="http://tuscany.apache.org/xmlns/sca/1.0"
+           xmlns:ns1="http://tuscany.apache.org/xmlns/sca/1.0">
+    <contribution location="file:./cloud"
+           uri="http://tuscany.apache.org/cloud" />
+    <contribution location="file:../../../../payment/target/itest-domainmgr-transaction-payment.jar"
+           uri="scatours-payment" />
+</workspace>