You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by hi...@apache.org on 2011/12/07 13:17:12 UTC
svn commit: r1211407 [1/7] - in /synapse/trunk/java/modules/integration: ./
src/ src/test/ src/test/java/ src/test/java/org/ src/test/java/org/apache/
src/test/java/org/apache/synapse/ src/test/java/org/apache/synapse/samples/
src/test/java/org/apache/...
Author: hiranya
Date: Wed Dec 7 12:17:10 2011
New Revision: 1211407
URL: http://svn.apache.org/viewvc?rev=1211407&view=rev
Log:
Starting to add the Synapse sample automation framework SYNAPSE-746
Added:
synapse/trunk/java/modules/integration/
synapse/trunk/java/modules/integration/pom.xml
synapse/trunk/java/modules/integration/src/
synapse/trunk/java/modules/integration/src/test/
synapse/trunk/java/modules/integration/src/test/java/
synapse/trunk/java/modules/integration/src/test/java/org/
synapse/trunk/java/modules/integration/src/test/java/org/apache/
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/Axis2BackEndServerController.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/BackEndServerController.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/DerbyServerController.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/JMSBrokerController.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/ProcessController.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleClientResult.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfigConstants.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfiguration.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SynapseProcessController.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SynapseTestCase.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SynapseTestUtils.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/TestSamplesHandlerSuite.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/clients/
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/clients/EventSampleClient.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/clients/JMSSampleClient.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/clients/MTOMSwASampleClient.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/clients/StockQuoteCallback.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/clients/StockQuoteHandler.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/clients/StockQuoteSampleClient.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample0.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample1.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample10.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample11.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample12.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample13.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample15.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample16.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample2.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample3.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample4.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample5.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample6.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample7.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample8.java
synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/tests/message/Sample9.java
synapse/trunk/java/modules/integration/src/test/resources/
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Client/
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Client/axis2_def.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Client/axis2_jms.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Client/axis2_tcp.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Client/axis2_udp.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Server/
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Server/axis2_clustering.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Server/axis2_def.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/axis2Server/axis2_jms.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/synapse/
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/synapse/axis2_clustering.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/synapse/axis2_def.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/synapse/axis2_fix.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/synapse/axis2_jms.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/synapse/axis2_tcp.xml
synapse/trunk/java/modules/integration/src/test/resources/axis2Xml/synapse/axis2_udp.xml
synapse/trunk/java/modules/integration/src/test/resources/identity.jks (with props)
synapse/trunk/java/modules/integration/src/test/resources/sample0.xml
synapse/trunk/java/modules/integration/src/test/resources/sample1.xml
synapse/trunk/java/modules/integration/src/test/resources/sample10.xml
synapse/trunk/java/modules/integration/src/test/resources/sample11.xml
synapse/trunk/java/modules/integration/src/test/resources/sample12.xml
synapse/trunk/java/modules/integration/src/test/resources/sample13.xml
synapse/trunk/java/modules/integration/src/test/resources/sample15.xml
synapse/trunk/java/modules/integration/src/test/resources/sample16.xml
synapse/trunk/java/modules/integration/src/test/resources/sample2.xml
synapse/trunk/java/modules/integration/src/test/resources/sample3.xml
synapse/trunk/java/modules/integration/src/test/resources/sample4.xml
synapse/trunk/java/modules/integration/src/test/resources/sample5.xml
synapse/trunk/java/modules/integration/src/test/resources/sample6.xml
synapse/trunk/java/modules/integration/src/test/resources/sample7.xml
synapse/trunk/java/modules/integration/src/test/resources/sample8.xml
synapse/trunk/java/modules/integration/src/test/resources/sample9.xml
synapse/trunk/java/modules/integration/src/test/resources/test-log4j.properties
synapse/trunk/java/modules/integration/src/test/resources/trust.jks (with props)
Added: synapse/trunk/java/modules/integration/pom.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/pom.xml?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/pom.xml (added)
+++ synapse/trunk/java/modules/integration/pom.xml Wed Dec 7 12:17:10 2011
@@ -0,0 +1,520 @@
+<?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
+ xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.synapse</groupId>
+ <artifactId>Apache-Synapse</artifactId>
+ <version>2.1.0-SNAPSHOT</version>
+ <relativePath>../../pom.xml</relativePath>
+ </parent>
+
+ <groupId>org.apache.synapse</groupId>
+ <artifactId>synapse-integration</artifactId>
+
+ <name>Apache Synapse - Integration</name>
+ <description>Apache Synapse - Sample Automation Framework</description>
+ <!--<packaging>bundle</packaging>-->
+
+ <build>
+ <plugins>
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-antrun-plugin</artifactId>
+ <version>1.6</version>
+ <executions>
+ <execution>
+ <id>create_repo</id>
+ <phase>generate-test-resources</phase>
+ <configuration>
+ <tasks>
+ <echo message="*** Creating testing repositories for synapse samples"/>
+
+ <mkdir dir="target/test_repos"/>
+ <mkdir dir="target/test_repos/axis2Server"/>
+ <mkdir dir="target/test_repos/axis2Client"/>
+ <mkdir dir="target/test_repos/synapse"/>
+ <mkdir dir="target/test_repos/synapse"/>
+ <mkdir dir="target/test_repos/synapse/modules"/>
+ <mkdir dir="target/test_repos/synapse/conf"/>
+ <mkdir dir="target/test_repos/axis2Server/services"/>
+ <mkdir dir="target/test_repos/axis2Server/modules"/>
+ <mkdir dir="target/test_repos/axis2Server/conf"/>
+ <mkdir dir="target/test_repos/axis2Client/modules"/>
+ <mkdir dir="target/test_repos/axis2Client/conf"/>
+
+ <copy todir="target/test_repos/axis2Server/conf/">
+ <fileset dir="src/test/resources/axis2Xml/axis2Server">
+ <include name="*.xml"/>
+ </fileset>
+ </copy>
+ <copy todir="target/test_repos/synapse/conf/">
+ <fileset dir="src/test/resources/axis2Xml/synapse">
+ <include name="*.xml"/>
+ </fileset>
+ </copy>
+ <copy todir="target/test_repos/axis2Client/conf/">
+ <fileset dir="src/test/resources/axis2Xml/axis2Client">
+ <include name="*.xml"/>
+ </fileset>
+ </copy>
+
+ <!--<copy file="src/test/resources/trust.jks"-->
+ <!--tofile="target/test_repos/synapse/conf/trust.jks"/>-->
+ <!--<copy file="src/test/resources/identity.jks"-->
+ <!--tofile="target/test_repos/synapse/conf/identity.jks"/>-->
+ <!--<copy file="../core/src/test/resources/keystore.jks"-->
+ <!--tofile="target/test_repos/synapse/conf/keystore.jks"/>-->
+
+ <property name="temp.dir" value="target/temp"/>
+ <property name="classes" value="${temp.dir}/classes"/>
+ <property name="services"
+ value="target/test_repos/axis2Server/services"/>
+
+ <property name="src"
+ value="../samples/services/SimpleStockQuoteService/src"/>
+
+ <mkdir dir="${temp.dir}"/>
+ <mkdir dir="${classes}"/>
+
+ <javac debug="on" destdir="${classes}" fork="true" includeantruntime="false">
+ <src path="${src}"/>
+ <classpath refid="maven.compile.classpath"/>
+ </javac>
+
+ <property name="SSQ.dir"
+ value="${temp.dir}/SimpleStockQuote"/>
+ <mkdir dir="${SSQ.dir}"/>
+
+ <mkdir dir="${SSQ.dir}/META-INF"/>
+ <copy file="${src}/../conf/services.xml"
+ tofile="${SSQ.dir}/META-INF/services.xml"/>
+ <!--<copy file="${src}/../wsdl/SimpleStockQuoteService.wsdl"-->
+ <!--tofile="${SSQ.dir}/META-INF/service.wsdl"/>-->
+ <copy toDir="${SSQ.dir}">
+ <fileset dir="${classes}">
+ <include name="**/*.class"/>
+ </fileset>
+ </copy>
+
+ <jar destfile="${services}/SimpleStockQuoteService.aar">
+ <fileset dir="${SSQ.dir}"/>
+ </jar>
+
+ <property name="src2"
+ value="../samples/services/SecureStockQuoteService/src"/>
+ <delete dir="${temp.dir}"/>
+ <mkdir dir="${temp.dir}"/>
+ <mkdir dir="${classes}"/>
+ <javac debug="on" destdir="${classes}" fork="true" includeantruntime="false">
+ <src path="${src2}"/>
+ <classpath refid="maven.compile.classpath"/>
+ </javac>
+ <property name="SSQ2.dir"
+ value="${temp.dir}/SecureStockQuoteService"/>
+ <mkdir dir="${SSQ2.dir}"/>
+ <mkdir dir="${SSQ2.dir}/META-INF"/>
+ <copy file="${src2}/../conf/services.xml"
+ tofile="${SSQ2.dir}/META-INF/services.xml"/>
+ <!--<copy file="${src2}/../wsdl/SimpleStockQuoteService.wsdl"-->
+ <!--tofile="${SSQ2.dir}/META-INF/service.wsdl"/>-->
+ <copy file="${src2}/../store.jks"
+ tofile="${SSQ2.dir}/store.jks"/>
+ <copy toDir="${SSQ2.dir}">
+ <fileset dir="${classes}">
+ <include name="**/*.class"/>
+ </fileset>
+ </copy>
+ <jar destfile="${services}/SecureStockQuoteService.aar">
+ <fileset dir="${SSQ2.dir}"/>
+ </jar>
+
+ <property name="src3"
+ value="../samples/services/MTOMSwASampleService/src"/>
+ <delete dir="${temp.dir}"/>
+ <mkdir dir="${temp.dir}"/>
+ <mkdir dir="${classes}"/>
+ <javac debug="on" destdir="${classes}" fork="true" includeantruntime="false">
+ <src path="${src3}"/>
+ <classpath refid="maven.compile.classpath"/>
+ </javac>
+ <property name="SSQ3.dir"
+ value="${temp.dir}/MTOMSwASampleService"/>
+ <mkdir dir="${SSQ3.dir}"/>
+ <mkdir dir="${SSQ3.dir}/META-INF"/>
+ <copy file="${src3}/../conf/services.xml"
+ tofile="${SSQ3.dir}/META-INF/services.xml"/>
+ <copy toDir="${SSQ3.dir}">
+ <fileset dir="${classes}">
+ <include name="**/*.class"/>
+ </fileset>
+ </copy>
+ <jar destfile="${services}/MTOMSwASampleService.aar">
+ <fileset dir="${SSQ3.dir}"/>
+ </jar>
+
+ <property name="src4"
+ value="../samples/services/ReliableStockQuoteService/src"/>
+ <delete dir="${temp.dir}"/>
+ <mkdir dir="${temp.dir}"/>
+ <mkdir dir="${classes}"/>
+ <javac debug="on" destdir="${classes}" fork="true" includeantruntime="false">
+ <src path="${src4}"/>
+ <classpath refid="maven.compile.classpath"/>
+ </javac>
+ <property name="RSQ.dir"
+ value="${temp.dir}/ReliableStockQuoteService"/>
+ <mkdir dir="${RSQ.dir}"/>
+
+ <mkdir dir="${RSQ.dir}/META-INF"/>
+ <copy file="${src4}/../conf/services.xml"
+ tofile="${RSQ.dir}/META-INF/services.xml"/>
+ <!--<copy file="${src4}/../wsdl/ReliableStockQuoteService.wsdl"-->
+ <!--tofile="${RSQ.dir}/META-INF/service.wsdl"/>-->
+ <copy toDir="${RSQ.dir}">
+ <fileset dir="${classes}">
+ <include name="**/*.class"/>
+ </fileset>
+ </copy>
+
+ <jar destfile="${services}/ReliableStockQuoteService.aar">
+ <fileset dir="${RSQ.dir}"/>
+ </jar>
+
+ <property name="src5"
+ value="../samples/services/LoadbalanceFailoverService/src"/>
+ <delete dir="${temp.dir}"/>
+ <mkdir dir="${temp.dir}"/>
+ <mkdir dir="${classes}"/>
+ <javac debug="on" destdir="${classes}" fork="true" includeantruntime="false">
+ <src path="${src5}"/>
+ <classpath refid="maven.compile.classpath"/>
+ </javac>
+
+ <property name="LBFA1.dir" value="${temp.dir}/LBService1"/>
+ <mkdir dir="${LBFA1.dir}"/>
+
+ <mkdir dir="${LBFA1.dir}/META-INF"/>
+ <copy file="${src5}/../conf/service1/services.xml"
+ tofile="${LBFA1.dir}/META-INF/services.xml"/>
+ <copy toDir="${LBFA1.dir}">
+ <fileset dir="${classes}">
+ <include name="**/LBService1.class"/>
+ </fileset>
+ </copy>
+
+ <jar destfile="${services}/LBService1.aar">
+ <fileset dir="${LBFA1.dir}"/>
+ </jar>
+
+ <property name="LBFA2.dir" value="${temp.dir}/LBService2"/>
+ <mkdir dir="${LBFA2.dir}"/>
+
+ <mkdir dir="${LBFA2.dir}/META-INF"/>
+ <copy file="${src5}/../conf/service2/services.xml"
+ tofile="${LBFA2.dir}/META-INF/services.xml"/>
+ <copy toDir="${LBFA2.dir}">
+ <fileset dir="${classes}">
+ <include name="**/LBService2.class"/>
+ </fileset>
+ </copy>
+
+ <jar destfile="${services}/LBService2.aar">
+ <fileset dir="${LBFA2.dir}"/>
+ </jar>
+
+ </tasks>
+ </configuration>
+ <goals>
+ <goal>run</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-dependency-plugin</artifactId>
+ <version>2.3</version>
+ <executions>
+ <execution>
+ <id>copy</id>
+ <phase>generate-test-resources</phase>
+ <goals>
+ <goal>copy</goal>
+ </goals>
+ <configuration>
+ <artifactItems>
+ <artifactItem>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>addressing</artifactId>
+ <version>${addressing.version}</version>
+ <type>mar</type>
+ <outputDirectory>target/test_repos/axis2Server/modules
+ </outputDirectory>
+ </artifactItem>
+
+ <artifactItem>
+ <groupId>org.apache.rampart</groupId>
+ <artifactId>rampart</artifactId>
+ <version>${rampart.version}</version>
+ <type>mar</type>
+ <outputDirectory>target/test_repos/axis2Server/modules
+ </outputDirectory>
+ </artifactItem>
+ <artifactItem>
+ <groupId>org.apache.sandesha2</groupId>
+ <artifactId>sandesha2</artifactId>
+ <version>${sandesha2.version}</version>
+ <type>mar</type>
+ <outputDirectory>target/test_repos/axis2Server/modules
+ </outputDirectory>
+ </artifactItem>
+ <artifactItem>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>addressing</artifactId>
+ <version>${addressing.version}</version>
+ <type>mar</type>
+ <outputDirectory>target/test_repos/axis2Client/modules
+ </outputDirectory>
+ </artifactItem>
+ <artifactItem>
+ <groupId>org.apache.rampart</groupId>
+ <artifactId>rampart</artifactId>
+ <version>${rampart.version}</version>
+ <type>mar</type>
+ <outputDirectory>target/test_repos/axis2Client/modules
+ </outputDirectory>
+ </artifactItem>
+
+ <artifactItem>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>addressing</artifactId>
+ <version>${addressing.version}</version>
+ <type>mar</type>
+ <outputDirectory>target/test_repos/synapse/modules
+ </outputDirectory>
+ </artifactItem>
+ <artifactItem>
+ <groupId>org.apache.rampart</groupId>
+ <artifactId>rampart</artifactId>
+ <version>${rampart.version}</version>
+ <type>mar</type>
+ <outputDirectory>target/test_repos/synapse/modules
+ </outputDirectory>
+ </artifactItem>
+ <artifactItem>
+ <groupId>org.apache.sandesha2</groupId>
+ <artifactId>sandesha2</artifactId>
+ <version>${sandesha2.version}</version>
+ <type>mar</type>
+ <outputDirectory>target/test_repos/synapse/modules
+ </outputDirectory>
+ </artifactItem>
+
+ </artifactItems>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <version>2.9</version>
+ <configuration>
+ <systemPropertyVariables>
+ <property>
+ <name>suite</name>
+ <value>${suite}</value>
+ <name>tests</name>
+ <value>${tests}</value>
+ </property>
+ <timeStamp>${maven.build.timestamp}</timeStamp>
+ <log4j.configuration>test-log4j.properties</log4j.configuration>
+ </systemPropertyVariables>
+ <argLine>-Xms512m -Xmx1024m -XX:MaxPermSize=512m</argLine>
+ <workingDirectory>../..</workingDirectory>
+ <!--redirectTestOutputToFile>true</redirectTestOutputToFile-->
+ <forkMode>pertest</forkMode>
+ </configuration>
+ </plugin>
+
+ </plugins>
+ </build>
+
+ <reporting>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-report-plugin</artifactId>
+ <version>2.7.2</version>
+ <configuration>
+ <outputName>sample_automation</outputName>
+ </configuration>
+ </plugin>
+ </plugins>
+ </reporting>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.synapse</groupId>
+ <artifactId>synapse-core</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.synapse</groupId>
+ <artifactId>synapse-commons</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.synapse</groupId>
+ <artifactId>synapse-extensions</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.synapse</groupId>
+ <artifactId>synapse-samples</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.synapse</groupId>
+ <artifactId>synapse-fix-transport</artifactId>
+ <version>${synapse.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.rampart</groupId>
+ <artifactId>rampart-core</artifactId>
+ <version>${rampart.version}</version>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>org.apache.woden</groupId>
+ <artifactId>woden-api</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>axis2-transport-base</artifactId>
+ <version>${axis2.transport.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>axis2-transport-jms</artifactId>
+ <version>${axis2.transport.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>axis2-transport-udp</artifactId>
+ <version>${axis2.transport.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>axis2-transport-tcp</artifactId>
+ <version>1.0.0</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.jruby</groupId>
+ <artifactId>jruby-complete</artifactId>
+ <version>${jruby.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.httpcomponents</groupId>
+ <artifactId>httpclient</artifactId>
+ <version>4.1</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>activemq-core</artifactId>
+ <version>5.5.0</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.derby</groupId>
+ <artifactId>derbyclient</artifactId>
+ <version>10.8.1.2</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.derby</groupId>
+ <artifactId>derbynet</artifactId>
+ <version>10.8.1.2</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-log4j12</artifactId>
+ <version>1.6.1</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ <version>1.6.1</version>
+ <scope>test</scope>
+ </dependency>
+ <!--<dependency>-->
+ <!--<groupId>org.slf4j</groupId>-->
+ <!--<artifactId>slf4j-jdk14</artifactId>-->
+ <!--<version>1.6.1</version>-->
+ <!--<scope>test</scope>-->
+ <!--</dependency>-->
+ <dependency>
+ <groupId>org.apache.derby</groupId>
+ <artifactId>derby</artifactId>
+ <version>10.8.1.2</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.neethi</groupId>
+ <artifactId>neethi</artifactId>
+ <version>3.0.1</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.mina</groupId>
+ <artifactId>mina-core</artifactId>
+ <version>1.1.7</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>quickfixj</groupId>
+ <artifactId>quickfixj-all</artifactId>
+ <version>1.4.0</version>
+ <scope>test</scope>
+ </dependency>
+ <!--dependency>
+ <groupId>quickfixj</groupId>
+ <artifactId>quickfixj-examples</artifactId>
+ <version>1.5.0</version>
+ <scope>test</scope>
+ </dependency-->
+ </dependencies>
+
+</project>
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/Axis2BackEndServerController.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/Axis2BackEndServerController.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/Axis2BackEndServerController.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/Axis2BackEndServerController.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,157 @@
+package org.apache.synapse.samples.framework;
+
+import org.apache.axis2.clustering.ClusteringAgent;
+import org.apache.axis2.clustering.ClusteringConstants;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.description.TransportInDescription;
+import org.apache.axis2.engine.ListenerManager;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import java.util.concurrent.CountDownLatch;
+
+/**
+ * Responsible for programatically starting up and shutting down
+ * an Axis2 server instance in order to run a sample test.
+ */
+public class Axis2BackEndServerController implements BackEndServerController {
+
+ private static final Log log = LogFactory.getLog(Axis2BackEndServerController.class);
+
+ private String serverName;
+ private BackEndServerThread serverThread;
+ private ConfigurationContext configContext;
+ private ListenerManager listenerManager;
+ private SampleConfiguration.Axis2SampleConfiguration configuration;
+ private CountDownLatch cdLatch;
+ private Exception processException;
+
+ public Axis2BackEndServerController(String serverName,
+ SampleConfiguration.Axis2SampleConfiguration configuration) {
+ this.serverName = serverName;
+ this.configuration = configuration;
+ serverThread = new BackEndServerThread();
+ serverThread.setName(configuration.getServerName()+ " thread");
+ cdLatch = new CountDownLatch(1);
+ }
+
+ public String getServerName() {
+ return serverName;
+ }
+
+ public boolean start() {
+ log.info("Preparing to start Axis2 Server: " + serverName);
+ serverThread.start();
+ try {
+ log.info("Waiting for Axis2 to start");
+ cdLatch.await();
+ if (processException == null) {
+ log.info("Axis2 is successfully started. continuing tests");
+ return true;
+ } else {
+ log.warn("There was an error starting Axis2 server: " + serverName, processException);
+ return false;
+ }
+ } catch (InterruptedException e) {
+ return false;
+ }
+ }
+
+ public boolean stop() {
+ if (serverThread.isRunning) {
+ serverThread.isRunning = false;
+ try {
+ cdLatch = new CountDownLatch(1);
+ cdLatch.await();
+ } catch (InterruptedException e) {
+ return false;
+ }
+ }
+ return true;
+ }
+
+ class BackEndServerThread extends Thread {
+
+ public boolean isRunning = false;
+
+ public void run() {processException = null;
+ log.info("ServerThread: Initializing Axis2 Server: " + serverName);
+ processException = null;
+ try {
+ listenerManager = new ListenerManager();
+
+ configContext = ConfigurationContextFactory
+ .createConfigurationContextFromFileSystem(configuration.getAxis2Repo(),
+ configuration.getAxis2Xml());
+
+ // setting System.setProperty does not work since this all servers are run on same jvm
+ configContext.setProperty("server_name", serverName);
+
+
+ TransportInDescription httpTrsIn = configContext.getAxisConfiguration().
+ getTransportsIn().get("http");
+ String httpPort = configuration.getHttpPort();
+ if (httpPort != null && !httpPort.isEmpty()) {
+ try {
+ new Integer(httpPort);
+ httpTrsIn.getParameter("port").setValue(httpPort);
+ } catch (NumberFormatException e) {
+ log.error("Given port is not a valid integer. Using default value.");
+ }
+ }
+
+ TransportInDescription httpsTrsIn = configContext.getAxisConfiguration().
+ getTransportsIn().get("https");
+ String httpsPort = configuration.getHttpsPort();
+ if (httpsPort != null && !httpsPort.isEmpty()) {
+ try {
+ new Integer(httpsPort);
+ httpsTrsIn.getParameter("port").setValue(httpsPort);
+ } catch (NumberFormatException e) {
+ log.error("Given port is not a valid integer. Using default value.");
+ }
+ }
+
+ log.info("ServerThread: Starting Axis2 Server: " + serverName);
+
+
+ ClusteringAgent clusteringAgent =
+ configContext.getAxisConfiguration().getClusteringAgent();
+ String avoidInit = ClusteringConstants.Parameters.AVOID_INITIATION;
+ if (clusteringAgent != null && clusteringAgent.getParameter(avoidInit) != null &&
+ ((String) clusteringAgent.getParameter(avoidInit).getValue()).
+ equalsIgnoreCase("true")) {
+ clusteringAgent.setConfigurationContext(configContext);
+ clusteringAgent.init();
+ }
+
+
+ listenerManager.startSystem(configContext);
+ isRunning = true;
+
+ } catch (Exception e) {
+ processException = e;
+ }
+ cdLatch.countDown();
+
+ log.info("ServerThread: Wait until test are finished");
+ while (isRunning) {
+ //wait
+ try {
+ sleep(1000);
+ } catch (InterruptedException e) {
+ log.info("Thread interrupted");
+ }
+ }
+ log.info("ServerThread: Shutting down Axis2 Server...");
+ try {
+ listenerManager.stop();
+ configContext.terminate();
+ } catch (Exception e) {
+ log.warn("Error while shutting down Axis2 server", e);
+ }
+ cdLatch.countDown();
+ }
+ }
+}
\ No newline at end of file
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/BackEndServerController.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/BackEndServerController.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/BackEndServerController.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/BackEndServerController.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,33 @@
+/*
+ * 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 org.apache.synapse.samples.framework;
+
+/**
+ * Specifies the operations associated with controlling
+ * backend server - starting up and shutting down.
+ */
+public interface BackEndServerController {
+
+ public String getServerName();
+
+ public boolean start();
+
+ public boolean stop();
+
+}
\ No newline at end of file
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/DerbyServerController.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/DerbyServerController.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/DerbyServerController.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/DerbyServerController.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,103 @@
+package org.apache.synapse.samples.framework;
+
+import org.apache.commons.io.FileUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.derby.drda.NetworkServerControl;
+
+import java.io.File;
+import java.net.InetAddress;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+/**
+ * Responsible for starting up and shutting down
+ * a derby server instance in order to run a sample test.
+ */
+public class DerbyServerController implements BackEndServerController {
+
+ private static final Log log = LogFactory.getLog(DerbyServerController.class);
+
+ private String serverName;
+ private SampleConfiguration.DerbyServerSampleConfiguration configuration;
+ private NetworkServerControl server;
+
+ public DerbyServerController(String serverName,
+ SampleConfiguration.DerbyServerSampleConfiguration configuration) {
+ this.serverName = serverName;
+ this.configuration = configuration;
+ }
+
+ public String getServerName() {
+ return serverName;
+ }
+
+ public boolean start() {
+ log.info("Preparing to start Derby server: " + serverName);
+ try {
+ //server
+ Class.forName("org.apache.derby.jdbc.ClientDriver").newInstance();
+ server = new NetworkServerControl
+ (InetAddress.getByName("localhost"), 1527);
+ server.start(null);
+ log.info("Derby is successfully started.");
+
+ } catch (Exception e) {
+ log.warn("There was an error starting Derby server: " + serverName, e);
+ return false;
+ }
+
+ //client
+ String dbName = "synapsedb";
+ String createTableQuery = "CREATE table company(name varchar(10), id varchar(10), price double)";
+ String connectionURL = "jdbc:derby://localhost:1527/" + dbName + ";create=true";
+
+ java.util.Properties props = new java.util.Properties();
+ props.put("user", "synapse");
+ props.put("password", "synapse");
+ props.put("create", "true");
+
+ try {
+ // on JDK 1.6 or higher, EmbeddedDriver get loaded automatically.
+ Class.forName("org.apache.derby.jdbc.ClientDriver").newInstance();
+
+ log.info("Creating the sample database and connecting to server");
+ Connection conn = DriverManager.getConnection(connectionURL, props);
+
+ Statement s = conn.createStatement();
+ log.info("Creating the sample table and inserting values");
+ s.execute(createTableQuery);
+ s.execute("INSERT into company values ('IBM','c1',0.0)");
+ s.execute(" INSERT into company values ('SUN','c2',0.0)");
+ s.execute(" INSERT into company values ('MSFT','c3',0.0)");
+ conn.commit();
+ return true;
+ } catch (Exception e) {
+ log.error("Error executing SQL queries", e);
+ return false;
+ }
+ }
+
+ public boolean stop() {
+ log.info("Shutting down Derby server...");
+ try {
+ try {
+ DriverManager.getConnection("jdbc:derby:;shutdown=true");
+ } catch (SQLException se) {
+ if (se.getErrorCode() == 50000 && "XJ015".equals(se.getSQLState())) {
+ // we got the expected exception
+ log.info("Derby shut down normally");
+ }
+ }
+ server.shutdown();
+ FileUtils.deleteDirectory(new File("./synapsedb"));
+ return true;
+
+ } catch (Exception e) {
+ log.warn("Error while trying to delete database directory", e);
+ return false;
+ }
+ }
+}
\ No newline at end of file
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/JMSBrokerController.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/JMSBrokerController.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/JMSBrokerController.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/JMSBrokerController.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,76 @@
+/*
+ * 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 org.apache.synapse.samples.framework;
+
+import org.apache.activemq.broker.BrokerService;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+/**
+ * Responsible for starting up and shutting down
+ * a JMS broker instance in order to run a sample test.
+ */
+public class JMSBrokerController implements BackEndServerController {
+
+ private static final Log log = LogFactory.getLog(JMSBrokerController.class);
+
+ private String serverName;
+ private SampleConfiguration.JMSBrokerSampleConfiguration configuration;
+ private BrokerService broker;
+
+ public JMSBrokerController(String serverName,
+ SampleConfiguration.JMSBrokerSampleConfiguration configuration) {
+ this.serverName = serverName;
+ this.configuration = configuration;
+ }
+
+ public String getServerName() {
+ return serverName;
+ }
+
+ public boolean start() {
+ try {
+ log.info("JMSServerController: Preparing to start JMS Broker: " + serverName);
+ //using embedded jms broker
+ broker = new BrokerService();
+ // configure the broker
+ broker.setBrokerName("synapseSampleBroker");
+ broker.addConnector(configuration.getProviderURL());
+ broker.start();
+ log.info("JMSServerController: Broker is Successfully started. continuing tests");
+ return true;
+ } catch (Exception e) {
+ log.error("JMSServerController: There was an error starting JMS broker: " +
+ serverName, e);
+ return false;
+ }
+ }
+
+ public boolean stop() {
+ try {
+ broker.stop();
+ return true;
+ } catch (Exception e) {
+ log.error("Error while shutting down the broker", e);
+ return false;
+ }
+ }
+
+}
\ No newline at end of file
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/ProcessController.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/ProcessController.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/ProcessController.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/ProcessController.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,32 @@
+/*
+ * 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 org.apache.synapse.samples.framework;
+
+/**
+ * Specifies the operations associated with controlling
+ * the mediation engine - starting up and shutting down.
+ */
+public interface ProcessController {
+
+ public boolean startProcess();
+
+ public boolean stopProcess();
+
+}
\ No newline at end of file
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleClientResult.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleClientResult.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleClientResult.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleClientResult.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,64 @@
+/*
+ * 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 org.apache.synapse.samples.framework;
+
+import java.util.Properties;
+
+/**
+ * Stores the results after executing a client
+ */
+public class SampleClientResult {
+
+ private boolean gotResponse;
+ private boolean isFinished;
+ private Exception exception;
+ private Properties clientProperties = new Properties();
+
+ public void setGotResponse(boolean gotResponse) {
+ this.gotResponse = gotResponse;
+ }
+
+ public void setException(Exception exception) {
+ this.exception = exception;
+ }
+
+ public boolean gotResponse() {
+ return gotResponse;
+ }
+
+ public Exception getException() {
+ return exception;
+ }
+
+ public boolean isFinished() {
+ return isFinished;
+ }
+
+ public void setFinished(boolean finished) {
+ isFinished = finished;
+ }
+
+ public void addProperty(String pName, String pValue){
+ clientProperties.setProperty(pName,pValue);
+ }
+
+ public String getProperty(String pName){
+ return clientProperties.getProperty(pName);
+ }
+}
\ No newline at end of file
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfigConstants.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfigConstants.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfigConstants.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfigConstants.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,79 @@
+/*
+ * 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 org.apache.synapse.samples.framework;
+
+/**
+ * Sample configuration constants
+ */
+public class SampleConfigConstants {
+
+ //xml tag names
+ public static final String TAG_SAMPLE_ID = "sampleID";
+ public static final String TAG_SAMPLE_NAME = "sampleName";
+
+ public static final String TAG_SYNAPSE_CONF = "synapseConfig";
+ public static final String TAG_SYNAPSE_CONF_AXIS2_REPO = "axis2Repo";
+ public static final String TAG_SYNAPSE_CONF_AXIS2_XML = "axis2Xml";
+ public static final String TAG_SYNAPSE_CONF_XML = "synapseXml";
+
+ public static final String TAG_BE_SERVER_CONF = "backEndServerConfig";
+ public static final String TAG_BE_SERVER_CONF_AXIS2_SERVER = "axis2Server";
+ public static final String TAG_BE_SERVER_CONF_JMS_BROKER = "jmsBroker";
+ public static final String TAG_BE_SERVER_CONF_DERBY_SERVER = "derbyServer";
+ public static final String TAG_BE_SERVER_CONF_QFIX_EXECUTOR = "fixExecutor";
+
+ public static final String TAG_BE_SERVER_CONF_AXIS2_REPO = "axis2Repo";
+ public static final String TAG_BE_SERVER_CONF_AXIS2_XML = "axis2Xml";
+ public static final String TAG_BE_SERVER_CONF_AXIS2_HTTP_PORT = "httpPort";
+ public static final String TAG_BE_SERVER_CONF_AXIS2_HTTPS_PORT = "httpsPort";
+
+ public static final String TAG_BE_SERVER_CONF_JMS_PROVIDER_URL = "providerURL";
+ public static final String TAG_BE_SERVER_CONF_JMS_INITIAL_NAMING_FACTORY = "initialNamingFactory";
+
+ public static final String TAG_CLIENT_CONF = "clientConfig";
+ public static final String TAG_CLIENT_CONF_REPO = "clientRepo";
+ public static final String TAG_CLIENT_CONF_AXIS2_XML = "axis2Xml";
+ public static final String TAG_CLIENT_CONF_FILENAME = "fileName";
+
+ public static final String TAG_ENABLE_CLUSTERING = "enableClustering";
+
+ //default values
+ public static final String DEFAULT_SYNAPSE_CONF_AXIS2_XML =
+ "modules/integration/target/test_repos/synapse/conf/axis2_def.xml";
+ public static final String DEFAULT_SYNAPSE_CONF_AXIS2_REPO =
+ "modules/integration/target/test_repos/synapse";
+
+ public static final String DEFAULT_BE_SERVER_CONF_AXIS2_XML =
+ "modules/integration/target/test_repos/axis2Server/conf/axis2_def.xml";
+ public static final String DEFAULT_BE_SERVER_CONF_AXIS2_REPO =
+ "modules/integration/target/test_repos/axis2Server";
+
+ public static final String DEFAULT_BE_SERVER_CONF_JMS_PROVIDER_URL = "tcp://localhost:61616";
+ public static final String DEFAULT_BE_SERVER_CONF_JMS_INITIAL_NAMING_FACTORY =
+ "org.apache.activemq.jndi.ActiveMQInitialContextFactory";
+
+ public static final String DEFAULT_CLIENT_CONF_REPO =
+ "modules/integration/target/test_repos/axis2Client";
+ public static final String DEFAULT_CLIENT_CONF_FILENAME =
+ "./repository/samples/resources/asf-logo.gif";
+ public static final String DEFAULT_CLIENT_CONF_AXIS2_XML =
+ "modules/integration/target/test_repos/axis2Client/conf/axis2_def.xml";
+
+
+}
\ No newline at end of file
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfiguration.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfiguration.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfiguration.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SampleConfiguration.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,301 @@
+/*
+ * 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 org.apache.synapse.samples.framework;
+
+import java.util.HashMap;
+import java.util.Set;
+
+/**
+* Stores the configuration information for Synapse, Axis2 Server and Clients.
+* All the information loaded from sample descriptor files are stored here.
+*/
+public class SampleConfiguration {
+ private String sampleName;
+ private SynapseSampleConfiguration synapseConfig;
+ private HashMap<String, Axis2SampleConfiguration> axis2Configs;
+ private HashMap<String, JMSBrokerSampleConfiguration> jmsConfigs;
+ private HashMap<String, DerbyServerSampleConfiguration> derbyConfigs;
+ private HashMap<String, FIXExecutorSampleConfiguration> executorConfigs;
+ private ClientSampleConfiguration clientConfig;
+
+ public SampleConfiguration() {
+ this.synapseConfig = new SynapseSampleConfiguration();
+ this.axis2Configs = new HashMap<String, Axis2SampleConfiguration>();
+ this.jmsConfigs = new HashMap<String, JMSBrokerSampleConfiguration>();
+ this.derbyConfigs = new HashMap<String, DerbyServerSampleConfiguration>();
+ this.executorConfigs = new HashMap<String, FIXExecutorSampleConfiguration>();
+ this.clientConfig = new ClientSampleConfiguration();
+ }
+
+ public String getSampleName() {
+ return sampleName;
+ }
+
+ public void setSampleName(String name) {
+ this.sampleName = sampleName;
+ }
+
+ public SynapseSampleConfiguration getSynapseConfig() {
+ return synapseConfig;
+ }
+
+ public void addNewAxis2Server(String name) {
+ axis2Configs.put(name, new Axis2SampleConfiguration());
+ }
+
+ public void addNewJMSBroker(String name) {
+ jmsConfigs.put(name, new JMSBrokerSampleConfiguration());
+ }
+
+ public void addNewDerbyServer(String name) {
+ derbyConfigs.put(name, new DerbyServerSampleConfiguration());
+ }
+
+ public void addNewFIXExecutor(String name) {
+ executorConfigs.put(name, new FIXExecutorSampleConfiguration());
+ }
+
+ public Axis2SampleConfiguration getAxis2Config(String name) {
+ return axis2Configs.get(name);
+ }
+
+ public JMSBrokerSampleConfiguration getJMSConfig(String name) {
+ return jmsConfigs.get(name);
+ }
+
+ public DerbyServerSampleConfiguration getDerbyConfig(String name) {
+ return derbyConfigs.get(name);
+ }
+
+ public FIXExecutorSampleConfiguration getFIXExecutorConfig(String name) {
+ return executorConfigs.get(name);
+ }
+
+ public Set<String> getAxis2ServersList() {
+ return axis2Configs.keySet();
+ }
+
+ public int getBackEndServerCount() {
+ return axis2Configs.size() + jmsConfigs.size();
+ }
+
+ public ClientSampleConfiguration getClientConfig() {
+ return clientConfig;
+ }
+
+ class SynapseSampleConfiguration {
+ private String serverName;
+ private String synapseHome;
+ private String axis2Repo;
+ private String axis2Xml;
+ private String synapseXml;
+ private boolean clusteringEnabled;
+
+ public String getServerName() {
+ return serverName;
+ }
+
+ public void setServerName(String serverName) {
+ this.serverName = serverName;
+ }
+
+ public String getSynapseHome() {
+ return synapseHome;
+ }
+
+ public void setSynapseHome(String synapseHome) {
+ this.synapseHome = synapseHome;
+ }
+
+ public String getAxis2Repo() {
+ return axis2Repo;
+ }
+
+ public void setAxis2Repo(String axis2Repo) {
+ this.axis2Repo = axis2Repo;
+ }
+
+ public String getAxis2Xml() {
+ return axis2Xml;
+ }
+
+ public void setAxis2Xml(String axis2Xml) {
+ this.axis2Xml = axis2Xml;
+ }
+
+ public String getSynapseXml() {
+ return synapseXml;
+ }
+
+ public void setSynapseXml(String synapseXml) {
+ this.synapseXml = synapseXml;
+ }
+
+ public boolean isClusteringEnabled() {
+ return clusteringEnabled;
+ }
+
+ public void setClusteringEnabled(boolean clusteringEnabled) {
+ this.clusteringEnabled = clusteringEnabled;
+ }
+ }
+
+ class Axis2SampleConfiguration {
+ private String serverName;
+ private String axis2Repo;
+ private String axis2Xml;
+ private String httpPort;
+ private String httpsPort;
+ private boolean clusteringEnabled;
+
+ public String getServerName() {
+ return serverName;
+ }
+
+ public void setServerName(String serverName) {
+ this.serverName = serverName;
+ }
+
+ public String getAxis2Repo() {
+ return axis2Repo;
+ }
+
+ public void setAxis2Repo(String axis2Repo) {
+ this.axis2Repo = axis2Repo;
+ }
+
+ public String getAxis2Xml() {
+ return axis2Xml;
+ }
+
+ public void setAxis2Xml(String axis2Xml) {
+ this.axis2Xml = axis2Xml;
+ }
+
+ public String getHttpPort() {
+ return httpPort;
+ }
+
+ public void setHttpPort(String httpPort) {
+ this.httpPort = httpPort;
+ }
+
+ public String getHttpsPort() {
+ return httpsPort;
+ }
+
+ public void setHttpsPort(String httpsPort) {
+ this.httpsPort = httpsPort;
+ }
+
+ public boolean isClusteringEnabled() {
+ return clusteringEnabled;
+ }
+
+ public void setClusteringEnabled(boolean clusteringEnabled) {
+ this.clusteringEnabled = clusteringEnabled;
+ }
+ }
+
+ class JMSBrokerSampleConfiguration {
+ private String serverName;
+ private String providerURL;
+ private String initialNamingFactory;
+
+ public String getServerName() {
+ return serverName;
+ }
+
+ public void setServerName(String serverName) {
+ this.serverName = serverName;
+ }
+
+ public String getProviderURL() {
+ return providerURL;
+ }
+
+ public void setProviderURL(String providerURL) {
+ this.providerURL = providerURL;
+ }
+
+ public String getInitialNamingFactory() {
+ return initialNamingFactory;
+ }
+
+ public void setInitialNamingFactory(String initialNamingFactory) {
+ this.initialNamingFactory = initialNamingFactory;
+ }
+ }
+
+
+ class DerbyServerSampleConfiguration {
+ private String serverName;
+
+ public String getServerName() {
+ return serverName;
+ }
+
+ public void setServerName(String serverName) {
+ this.serverName = serverName;
+ }
+ }
+
+ class FIXExecutorSampleConfiguration {
+ private String serverName;
+
+ public String getServerName() {
+ return serverName;
+ }
+
+ public void setServerName(String serverName) {
+ this.serverName = serverName;
+ }
+ }
+
+ public class ClientSampleConfiguration {
+ private String clientRepo;
+ private String fileName;
+ private String axis2Xml;
+
+ public String getClientRepo() {
+ return clientRepo;
+ }
+
+ public void setClientRepo(String clientRepo) {
+ this.clientRepo = clientRepo;
+ }
+
+ public String getFileName() {
+ return fileName;
+ }
+
+ public void setFileName(String fileName) {
+ this.fileName = fileName;
+ }
+
+ public String getAxis2Xml() {
+ return axis2Xml;
+ }
+
+ public void setAxis2Xml(String axis2Xml) {
+ this.axis2Xml = axis2Xml;
+ }
+ }
+
+}
\ No newline at end of file
Added: synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SynapseProcessController.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SynapseProcessController.java?rev=1211407&view=auto
==============================================================================
--- synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SynapseProcessController.java (added)
+++ synapse/trunk/java/modules/integration/src/test/java/org/apache/synapse/samples/framework/SynapseProcessController.java Wed Dec 7 12:17:10 2011
@@ -0,0 +1,123 @@
+/*
+ * 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 org.apache.synapse.samples.framework;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.synapse.ServerConfigurationInformation;
+import org.apache.synapse.ServerManager;
+
+import java.util.concurrent.CountDownLatch;
+
+/**
+ * Responsible for starting up and shutting down
+ * a synapse server instance in order to run a sample test.
+ */
+public class SynapseProcessController implements ProcessController {
+
+ private static final Log log = LogFactory.getLog(SynapseProcessController.class);
+
+ private ServerThread serverThread;
+ private SampleConfiguration.SynapseSampleConfiguration configuration;
+ private ServerConfigurationInformation information;
+ private ServerManager manager;
+ private CountDownLatch cdLatch;
+ private Exception processException;
+
+ public SynapseProcessController(SampleConfiguration.SynapseSampleConfiguration configuration) {
+ this.configuration = configuration;
+ information = new ServerConfigurationInformation();
+ manager = new ServerManager();
+ cdLatch = new CountDownLatch(1);
+ serverThread = new ServerThread();
+ serverThread.setName(configuration.getServerName() + " thread");
+ }
+
+ public boolean startProcess() {
+ information.setSynapseHome(configuration.getSynapseHome());
+ information.setSynapseXMLLocation(configuration.getSynapseXml());
+ information.setServerName(configuration.getServerName());
+ information.setAxis2Xml(configuration.getAxis2Xml());
+ information.setResolveRoot(configuration.getAxis2Repo());
+ information.setAxis2RepoLocation(configuration.getAxis2Repo());
+
+ log.info("SynapseProcessController: Preparing to start synapse server");
+ serverThread.start();
+
+ try {
+ log.info("SynapseProcessController: Waiting for synapse to start");
+ cdLatch.await();
+ if (processException == null) {
+ log.info("SynapseProcessController: synapse is started. continuing tests");
+ return true;
+ } else {
+ log.warn("SynapseProcessController: There was an error starting synapse", processException);
+ return false;
+ }
+ } catch (InterruptedException e) {
+ return false;
+ }
+ }
+
+ public boolean stopProcess() {
+ if (serverThread.isRunning) {
+ serverThread.isRunning = false;
+ try {
+ cdLatch = new CountDownLatch(1);
+ cdLatch.await();
+ } catch (InterruptedException e) {
+ log.warn("Thread interrupted");
+ }
+ }
+ return true;
+ }
+
+ private class ServerThread extends Thread {
+
+ public boolean isRunning = false;
+
+ public void run() {
+ processException = null;
+ log.info("SynapseProcessController.ServerThread: Initializing Synapse Server...");
+ try {
+ manager.init(information, null);
+ log.info("SynapseProcessController.ServerThread: Starting Synapse Server...");
+ manager.start();
+ isRunning = true;
+ } catch (Exception e) {
+ processException = e;
+ }
+ cdLatch.countDown();
+
+ log.info("SynapseProcessController.ServerThread: Await until test are finished");
+ while (isRunning) {
+ //wait
+ try {
+ sleep(1000);
+ } catch (InterruptedException e) {
+ log.warn("Thread interrupted");
+ }
+ }
+ log.info("SynapseProcessController.ServerThread:Shutting down Synapse Server...");
+ manager.shutdown();
+ cdLatch.countDown();
+ }
+ }
+
+}
\ No newline at end of file
Re: svn commit: r1211407 [1/7] - in /synapse/trunk/java/modules/integration:
./ src/ src/test/ src/test/java/ src/test/java/org/ src/test/java/org/apache/
src/test/java/org/apache/synapse/ src/test/java/org/apache/synapse/samples/ src/test/java/org/apache/...
Posted by Andreas Veithen <an...@gmail.com>.
I understand the reason now. See r1547184.
Andreas
On Sun, Nov 24, 2013 at 8:41 PM, Hiranya Jayathilaka
<hi...@gmail.com> wrote:
> Hi Andreas,
>
> On Nov 24, 2013, at 3:30 AM, Andreas Veithen <an...@gmail.com>
> wrote:
>
> On Wed, Dec 7, 2011 at 1:17 PM, <hi...@apache.org> wrote:
>
> + <plugin>
> + <groupId>org.apache.maven.plugins</groupId>
> + <artifactId>maven-surefire-plugin</artifactId>
> + <version>2.9</version>
> + <configuration>
> + <systemPropertyVariables>
> + <property>
> + <name>suite</name>
> + <value>${suite}</value>
> + <name>tests</name>
> + <value>${tests}</value>
> + </property>
> + <timeStamp>${maven.build.timestamp}</timeStamp>
> +
> <log4j.configuration>test-log4j.properties</log4j.configuration>
> + </systemPropertyVariables>
> + <argLine>-Xms512m -Xmx1024m
> -XX:MaxPermSize=512m</argLine>
> + <workingDirectory>../..</workingDirectory>
> +
> <!--redirectTestOutputToFile>true</redirectTestOutputToFile-->
> + <forkMode>pertest</forkMode>
> + </configuration>
> + </plugin>
>
>
> Is there a particular reason to configure the working directory for
> the tests like this in the synapse-integration module? By default,
> surefire uses the Maven project directory, and this is also what
> Eclipse uses by default. So, by changing the setup of the integration
> tests to use the default directory, we would make it easier to run
> them in Eclipse.
>
>
> I cannot recall any specific reasons. If it doesn't break anything, please
> go ahead and do the necessary changes. I think the ability to run
> integration tests in an IDE is a very useful feature.
>
> Thanks,
> Hiranya
>
>
> Andreas
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: dev-unsubscribe@synapse.apache.org
> For additional commands, e-mail: dev-help@synapse.apache.org
>
>
> --
> Hiranya Jayathilaka
> Mayhem Lab/RACE Lab;
> Dept. of Computer Science, UCSB; http://cs.ucsb.edu
> E-mail: hiranya@cs.ucsb.edu; Mobile: +1 (805) 895-7443
> Blog: http://techfeast-hiranya.blogspot.com
>
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
Re: svn commit: r1211407 [1/7] - in /synapse/trunk/java/modules/integration: ./ src/ src/test/ src/test/java/ src/test/java/org/ src/test/java/org/apache/ src/test/java/org/apache/synapse/ src/test/java/org/apache/synapse/samples/ src/test/java/org/apache/...
Posted by Hiranya Jayathilaka <hi...@gmail.com>.
Hi Andreas,
On Nov 24, 2013, at 3:30 AM, Andreas Veithen <an...@gmail.com> wrote:
> On Wed, Dec 7, 2011 at 1:17 PM, <hi...@apache.org> wrote:
>> + <plugin>
>> + <groupId>org.apache.maven.plugins</groupId>
>> + <artifactId>maven-surefire-plugin</artifactId>
>> + <version>2.9</version>
>> + <configuration>
>> + <systemPropertyVariables>
>> + <property>
>> + <name>suite</name>
>> + <value>${suite}</value>
>> + <name>tests</name>
>> + <value>${tests}</value>
>> + </property>
>> + <timeStamp>${maven.build.timestamp}</timeStamp>
>> + <log4j.configuration>test-log4j.properties</log4j.configuration>
>> + </systemPropertyVariables>
>> + <argLine>-Xms512m -Xmx1024m -XX:MaxPermSize=512m</argLine>
>> + <workingDirectory>../..</workingDirectory>
>> + <!--redirectTestOutputToFile>true</redirectTestOutputToFile-->
>> + <forkMode>pertest</forkMode>
>> + </configuration>
>> + </plugin>
>
> Is there a particular reason to configure the working directory for
> the tests like this in the synapse-integration module? By default,
> surefire uses the Maven project directory, and this is also what
> Eclipse uses by default. So, by changing the setup of the integration
> tests to use the default directory, we would make it easier to run
> them in Eclipse.
I cannot recall any specific reasons. If it doesn't break anything, please go ahead and do the necessary changes. I think the ability to run integration tests in an IDE is a very useful feature.
Thanks,
Hiranya
>
> Andreas
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: dev-unsubscribe@synapse.apache.org
> For additional commands, e-mail: dev-help@synapse.apache.org
>
--
Hiranya Jayathilaka
Mayhem Lab/RACE Lab;
Dept. of Computer Science, UCSB; http://cs.ucsb.edu
E-mail: hiranya@cs.ucsb.edu; Mobile: +1 (805) 895-7443
Blog: http://techfeast-hiranya.blogspot.com
Re: svn commit: r1211407 [1/7] - in /synapse/trunk/java/modules/integration:
./ src/ src/test/ src/test/java/ src/test/java/org/ src/test/java/org/apache/
src/test/java/org/apache/synapse/ src/test/java/org/apache/synapse/samples/ src/test/java/org/apache/...
Posted by Andreas Veithen <an...@gmail.com>.
On Wed, Dec 7, 2011 at 1:17 PM, <hi...@apache.org> wrote:
> + <plugin>
> + <groupId>org.apache.maven.plugins</groupId>
> + <artifactId>maven-surefire-plugin</artifactId>
> + <version>2.9</version>
> + <configuration>
> + <systemPropertyVariables>
> + <property>
> + <name>suite</name>
> + <value>${suite}</value>
> + <name>tests</name>
> + <value>${tests}</value>
> + </property>
> + <timeStamp>${maven.build.timestamp}</timeStamp>
> + <log4j.configuration>test-log4j.properties</log4j.configuration>
> + </systemPropertyVariables>
> + <argLine>-Xms512m -Xmx1024m -XX:MaxPermSize=512m</argLine>
> + <workingDirectory>../..</workingDirectory>
> + <!--redirectTestOutputToFile>true</redirectTestOutputToFile-->
> + <forkMode>pertest</forkMode>
> + </configuration>
> + </plugin>
Is there a particular reason to configure the working directory for
the tests like this in the synapse-integration module? By default,
surefire uses the Maven project directory, and this is also what
Eclipse uses by default. So, by changing the setup of the integration
tests to use the default directory, we would make it easier to run
them in Eclipse.
Andreas
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org