Menu
▾
▴
[Cse-ip-svn-commits] SF.net SVN: cse-ip:[6] trunk/sandbox/campussource-cse
|
From: <id...@us...> - 2009-02-16 16:00:38
|
Revision: 6
http://cse-ip.svn.sourceforge.net/cse-ip/?rev=6&view=rev
Author: idueppe
Date: 2009-02-16 16:00:24 +0000 (Mon, 16 Feb 2009)
Log Message:
-----------
+Add unit test and a additional java bean route
+Add File Endpoint configuration
Modified Paths:
--------------
trunk/sandbox/campussource-cse/.classpath
trunk/sandbox/campussource-cse/.project
trunk/sandbox/campussource-cse/pom.xml
trunk/sandbox/campussource-cse/src/main/resources/META-INF/spring/camel-context.xml
Added Paths:
-----------
trunk/sandbox/campussource-cse/src/main/java/de/campussource/cse/BeanRouter.java
trunk/sandbox/campussource-cse/src/test/
trunk/sandbox/campussource-cse/src/test/java/
trunk/sandbox/campussource-cse/src/test/java/de/
trunk/sandbox/campussource-cse/src/test/java/de/campussource/
trunk/sandbox/campussource-cse/src/test/java/de/campussource/cse/
trunk/sandbox/campussource-cse/src/test/java/de/campussource/cse/CamelTest.java
Modified: trunk/sandbox/campussource-cse/.classpath
===================================================================
--- trunk/sandbox/campussource-cse/.classpath 2009-02-16 13:37:23 UTC (rev 5)
+++ trunk/sandbox/campussource-cse/.classpath 2009-02-16 16:00:24 UTC (rev 6)
@@ -1,19 +1,72 @@
<classpath>
+ <classpathentry kind="src" path="src/main/java"/>
<classpathentry kind="src" path="src/main/resources" excluding="**/*.java"/>
+ <classpathentry kind="src" path="src/test/java" output="target/test-classes"/>
<classpathentry kind="output" path="target/classes"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
- <classpathentry kind="var" path="M2_REPO/org/apache/camel/camel-core/1.5.0/camel-core-1.5.0.jar" sourcepath="M2_REPO/org/apache/camel/camel-core/1.5.0/camel-core-1.5.0-sources.jar"/>
- <classpathentry kind="var" path="M2_REPO/commons-logging/commons-logging-api/1.1/commons-logging-api-1.1.jar"/>
- <classpathentry kind="var" path="M2_REPO/org/apache/camel/camel-spring/1.5.0/camel-spring-1.5.0.jar" sourcepath="M2_REPO/org/apache/camel/camel-spring/1.5.0/camel-spring-1.5.0-sources.jar"/>
- <classpathentry kind="var" path="M2_REPO/org/springframework/spring-core/2.5.5/spring-core-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-core/2.5.5/spring-core-2.5.5-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/javax/activation/activation/1.1/activation-1.1.jar" sourcepath="M2_REPO/javax/activation/activation/1.1/activation-1.1-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/activemq/activeio-core/3.1.0/activeio-core-3.1.0.jar" sourcepath="M2_REPO/org/apache/activemq/activeio-core/3.1.0/activeio-core-3.1.0-sources.jar">
+ <attributes>
+ <attribute value="jar:file:/D:/Development/repository/org/apache/activemq/activeio-core/3.1.0/activeio-core-3.1.0-javadoc.jar!/" name="javadoc_location"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="var" path="M2_REPO/org/apache/activemq/activemq-camel/5.2.0/activemq-camel-5.2.0.jar" sourcepath="M2_REPO/org/apache/activemq/activemq-camel/5.2.0/activemq-camel-5.2.0-sources.jar">
+ <attributes>
+ <attribute value="jar:file:/D:/Development/repository/org/apache/activemq/activemq-camel/5.2.0/activemq-camel-5.2.0-javadoc.jar!/" name="javadoc_location"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="var" path="M2_REPO/org/apache/activemq/activemq-core/5.2.0/activemq-core-5.2.0.jar" sourcepath="M2_REPO/org/apache/activemq/activemq-core/5.2.0/activemq-core-5.2.0-sources.jar">
+ <attributes>
+ <attribute value="jar:file:/D:/Development/repository/org/apache/activemq/activemq-core/5.2.0/activemq-core-5.2.0-javadoc.jar!/" name="javadoc_location"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="var" path="M2_REPO/org/apache/activemq/activemq-pool/5.2.0/activemq-pool-5.2.0.jar" sourcepath="M2_REPO/org/apache/activemq/activemq-pool/5.2.0/activemq-pool-5.2.0-sources.jar">
+ <attributes>
+ <attribute value="jar:file:/D:/Development/repository/org/apache/activemq/activemq-pool/5.2.0/activemq-pool-5.2.0-javadoc.jar!/" name="javadoc_location"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="var" path="M2_REPO/aopalliance/aopalliance/1.0/aopalliance-1.0.jar" sourcepath="M2_REPO/aopalliance/aopalliance/1.0/aopalliance-1.0-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/backport-util-concurrent/backport-util-concurrent/2.1/backport-util-concurrent-2.1.jar" sourcepath="M2_REPO/backport-util-concurrent/backport-util-concurrent/2.1/backport-util-concurrent-2.1-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/camel/camel-core/1.5.0/camel-core-1.5.0.jar" sourcepath="M2_REPO/org/apache/camel/camel-core/1.5.0/camel-core-1.5.0-sources.jar">
+ <attributes>
+ <attribute value="jar:file:/D:/Development/repository/org/apache/camel/camel-core/1.5.0/camel-core-1.5.0-javadoc.jar!/" name="javadoc_location"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="var" path="M2_REPO/org/apache/camel/camel-jms/1.5.0/camel-jms-1.5.0.jar" sourcepath="M2_REPO/org/apache/camel/camel-jms/1.5.0/camel-jms-1.5.0-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/camel/camel-spring/1.5.0/camel-spring-1.5.0.jar" sourcepath="M2_REPO/org/apache/camel/camel-spring/1.5.0/camel-spring-1.5.0-sources.jar">
+ <attributes>
+ <attribute value="jar:file:/D:/Development/repository/org/apache/camel/camel-spring/1.5.0/camel-spring-1.5.0-javadoc.jar!/" name="javadoc_location"/>
+ </attributes>
+ </classpathentry>
<classpathentry kind="var" path="M2_REPO/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1.jar" sourcepath="M2_REPO/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1-sources.jar">
<attributes>
- <attribute value="jar:file:/C:/development/repository/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1-javadoc.jar!/" name="javadoc_location"/>
+ <attribute value="jar:file:/D:/Development/repository/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1-javadoc.jar!/" name="javadoc_location"/>
</attributes>
</classpathentry>
+ <classpathentry kind="var" path="M2_REPO/commons-logging/commons-logging-api/1.1/commons-logging-api-1.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/commons-pool/commons-pool/1.4/commons-pool-1.4.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/geronimo/specs/geronimo-j2ee-management_1.0_spec/1.0/geronimo-j2ee-management_1.0_spec-1.0.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/geronimo/specs/geronimo-jms_1.1_spec/1.1.1/geronimo-jms_1.1_spec-1.1.1.jar" sourcepath="M2_REPO/org/apache/geronimo/specs/geronimo-jms_1.1_spec/1.1.1/geronimo-jms_1.1_spec-1.1.1-sources.jar">
+ <attributes>
+ <attribute value="jar:file:/D:/Development/repository/org/apache/geronimo/specs/geronimo-jms_1.1_spec/1.1.1/geronimo-jms_1.1_spec-1.1.1-javadoc.jar!/" name="javadoc_location"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="var" path="M2_REPO/org/apache/geronimo/specs/geronimo-jta_1.0.1B_spec/1.0.1/geronimo-jta_1.0.1B_spec-1.0.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/geronimo/specs/geronimo-jta_1.1_spec/1.1.1/geronimo-jta_1.1_spec-1.1.1.jar" sourcepath="M2_REPO/org/apache/geronimo/specs/geronimo-jta_1.1_spec/1.1.1/geronimo-jta_1.1_spec-1.1.1-sources.jar">
+ <attributes>
+ <attribute value="jar:file:/D:/Development/repository/org/apache/geronimo/specs/geronimo-jta_1.1_spec/1.1.1/geronimo-jta_1.1_spec-1.1.1-javadoc.jar!/" name="javadoc_location"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="var" path="M2_REPO/javax/xml/bind/jaxb-api/2.1/jaxb-api-2.1.jar" sourcepath="M2_REPO/javax/xml/bind/jaxb-api/2.1/jaxb-api-2.1-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/com/sun/xml/bind/jaxb-impl/2.1.7/jaxb-impl-2.1.7.jar" sourcepath="M2_REPO/com/sun/xml/bind/jaxb-impl/2.1.7/jaxb-impl-2.1.7-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/junit/junit/4.5/junit-4.5.jar" sourcepath="M2_REPO/junit/junit/4.5/junit-4.5-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/log4j/log4j/1.2.14/log4j-1.2.14.jar" sourcepath="M2_REPO/log4j/log4j/1.2.14/log4j-1.2.14-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/springframework/spring-aop/2.5.5/spring-aop-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-aop/2.5.5/spring-aop-2.5.5-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/springframework/spring-beans/2.5.5/spring-beans-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-beans/2.5.5/spring-beans-2.5.5-sources.jar"/>
<classpathentry kind="var" path="M2_REPO/org/springframework/spring-context/2.5.5/spring-context-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-context/2.5.5/spring-context-2.5.5-sources.jar"/>
- <classpathentry kind="var" path="M2_REPO/aopalliance/aopalliance/1.0/aopalliance-1.0.jar" sourcepath="M2_REPO/aopalliance/aopalliance/1.0/aopalliance-1.0-sources.jar"/>
- <classpathentry kind="var" path="M2_REPO/org/springframework/spring-beans/2.5.5/spring-beans-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-beans/2.5.5/spring-beans-2.5.5-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/springframework/spring-context-support/2.5.5/spring-context-support-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-context-support/2.5.5/spring-context-support-2.5.5-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/springframework/spring-core/2.5.5/spring-core-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-core/2.5.5/spring-core-2.5.5-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/springframework/spring-jms/2.5.5/spring-jms-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-jms/2.5.5/spring-jms-2.5.5-sources.jar"/>
<classpathentry kind="var" path="M2_REPO/org/springframework/spring-tx/2.5.5/spring-tx-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-tx/2.5.5/spring-tx-2.5.5-sources.jar"/>
- <classpathentry kind="var" path="M2_REPO/org/springframework/spring-aop/2.5.5/spring-aop-2.5.5.jar" sourcepath="M2_REPO/org/springframework/spring-aop/2.5.5/spring-aop-2.5.5-sources.jar"/>
+ <classpathentry kind="var" path="M2_REPO/javax/xml/stream/stax-api/1.0-2/stax-api-1.0-2.jar" sourcepath="M2_REPO/javax/xml/stream/stax-api/1.0-2/stax-api-1.0-2-sources.jar"/>
</classpath>
\ No newline at end of file
Modified: trunk/sandbox/campussource-cse/.project
===================================================================
--- trunk/sandbox/campussource-cse/.project 2009-02-16 13:37:23 UTC (rev 5)
+++ trunk/sandbox/campussource-cse/.project 2009-02-16 16:00:24 UTC (rev 6)
@@ -6,8 +6,17 @@
<buildCommand>
<name>org.eclipse.jdt.core.javabuilder</name>
</buildCommand>
+ <buildCommand>
+ <name>org.eclipse.wst.common.project.facet.core.builder</name>
+ </buildCommand>
+ <buildCommand>
+ <name>org.eclipse.wst.validation.validationbuilder</name>
+ </buildCommand>
</buildSpec>
<natures>
+ <nature>org.eclipse.wst.common.project.facet.core.nature</nature>
<nature>org.eclipse.jdt.core.javanature</nature>
+ <nature>org.eclipse.wst.common.modulecore.ModuleCoreNature</nature>
+ <nature>org.eclipse.jem.workbench.JavaEMFNature</nature>
</natures>
</projectDescription>
\ No newline at end of file
Modified: trunk/sandbox/campussource-cse/pom.xml
===================================================================
--- trunk/sandbox/campussource-cse/pom.xml 2009-02-16 13:37:23 UTC (rev 5)
+++ trunk/sandbox/campussource-cse/pom.xml 2009-02-16 16:00:24 UTC (rev 6)
@@ -49,6 +49,12 @@
<artifactId>log4j</artifactId>
<version>1.2.14</version>
</dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.5</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
<build>
Added: trunk/sandbox/campussource-cse/src/main/java/de/campussource/cse/BeanRouter.java
===================================================================
--- trunk/sandbox/campussource-cse/src/main/java/de/campussource/cse/BeanRouter.java (rev 0)
+++ trunk/sandbox/campussource-cse/src/main/java/de/campussource/cse/BeanRouter.java 2009-02-16 16:00:24 UTC (rev 6)
@@ -0,0 +1,19 @@
+package de.campussource.cse;
+
+import org.apache.camel.Body;
+import org.apache.camel.EndpointInject;
+import org.apache.camel.Header;
+import org.apache.camel.ProducerTemplate;
+
+public class BeanRouter {
+
+ @EndpointInject(uri="activemq:SplittedMessagesAsFile")
+ private ProducerTemplate producer;
+
+ public void route(@Header(name="x") String header, @Body String body) {
+ System.out.println("Header "+header);
+ System.out.println("Header "+body);
+ producer.sendBody(body);
+ }
+
+}
Property changes on: trunk/sandbox/campussource-cse/src/main/java/de/campussource/cse/BeanRouter.java
___________________________________________________________________
Added: svn:mime-type
+ text/plain
Modified: trunk/sandbox/campussource-cse/src/main/resources/META-INF/spring/camel-context.xml
===================================================================
--- trunk/sandbox/campussource-cse/src/main/resources/META-INF/spring/camel-context.xml 2009-02-16 13:37:23 UTC (rev 5)
+++ trunk/sandbox/campussource-cse/src/main/resources/META-INF/spring/camel-context.xml 2009-02-16 16:00:24 UTC (rev 6)
@@ -1,51 +1,59 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns:csesm="http://cse.campussource.de/lsf/schema/SynchronizationMessage"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns:csesm="http://cse.campussource.de/lsf/schema/SynchronizationMessage"
+ xmlns:camel="http://activemq.apache.org/camel/schema/spring"
+ xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
<bean id="activemq" class="org.apache.camel.component.jms.JmsComponent">
- <property name="connectionFactory">
- <bean class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL" value="vm://localhost?broker.persistent=false"/>
- </bean>
- </property>
+ <property name="connectionFactory">
+ <bean class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="vm://localhost?broker.persistent=false" />
+ </bean>
+ </property>
</bean>
+
+ <bean id="Transformer" class="de.campussource.cse.ContentEnricher" />
+ <bean id="beanRouter" class="de.campussource.cse.BeanRouter"/>
- <bean id="Transformer" class="de.campussource.cse.ContentEnricher"/>
-
-
- <camelContext xmlns="http://activemq.apache.org/camel/schema/spring">
- <package>de.campussource.cse</package>
-
- <route>
- <from uri="file:src/data?noop=true"/>
- <to uri="xslt:xslt/transformation.xsl"/>
- <to uri="file:target/messages/LSFTransformedOutput"/>
- </route>
- <route>
-
- <from uri="activemq:BeforeSplitting"/>
- <splitter>
- <xpath>/csesm:synchronizationMessage/csesm:accounts/csesm:account</xpath>
- <to uri="activemq:SplittedLSFMessages"/>
- </splitter>
- </route>
- <route>
- <from uri="activemq:SplittedMessagesAsFile"/>
- <choice>
- <when>
- <xpath>/csesm:account/csesm:surname = 'Hansen'</xpath>
- <to uri="file:target/messages/account/Hansen"/>
- </when>
- <otherwise>
- <to uri="file:target/messages/account/others"/>
- </otherwise>
- </choice>
- </route>
- </camelContext>
+ <camel:camelContext xmlns="http://activemq.apache.org/camel/schema/spring">
+ <camel:package>de.campussource.cse</camel:package>
+ <camel:route>
+ <camel:from uri="file:target/input?moveNamePrefix=done/" />
+ <camel:to uri="xslt:xslt/transformation.xsl" />
+ <camel:to uri="file:target/messages/LSFTransformedOutput" />
+ </camel:route>
+
+ <camel:route>
+ <camel:from uri="file:target/input2?noop=false"/>
+ <camel:bean ref="beanRouter" method="route"/>
+ </camel:route>
+
+ <camel:route>
+ <camel:from uri="activemq:BeforeSplitting" />
+ <camel:splitter>
+ <camel:xpath>/csesm:synchronizationMessage/csesm:accounts/csesm:account</camel:xpath>
+ <camel:to uri="activemq:SplittedLSFMessages" />
+ </camel:splitter>
+ </camel:route>
+
+ <camel:route>
+ <camel:from uri="activemq:SplittedMessagesAsFile" />
+ <camel:choice>
+ <camel:when>
+ <camel:xpath>/csesm:account/csesm:surname = 'Hansen'</camel:xpath>
+ <camel:to uri="file:target/messages/account/Hansen" />
+ </camel:when>
+ <camel:otherwise>
+ <camel:to uri="file:target/messages/account/others" />
+ </camel:otherwise>
+ </camel:choice>
+ </camel:route>
+
+
+ </camel:camelContext>
+
</beans>
Added: trunk/sandbox/campussource-cse/src/test/java/de/campussource/cse/CamelTest.java
===================================================================
--- trunk/sandbox/campussource-cse/src/test/java/de/campussource/cse/CamelTest.java (rev 0)
+++ trunk/sandbox/campussource-cse/src/test/java/de/campussource/cse/CamelTest.java 2009-02-16 16:00:24 UTC (rev 6)
@@ -0,0 +1,21 @@
+package de.campussource.cse;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.spring.SpringCamelContext;
+import org.junit.Test;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class CamelTest {
+
+ @Test
+ public void testRouter() throws Exception {
+ ApplicationContext appContext = new ClassPathXmlApplicationContext("META-INF/spring/camel-context.xml");
+ CamelContext context = new SpringCamelContext(appContext);
+ context.start();
+ System.out.println("Camel Started");
+ System.in.read();
+ context.stop();
+ }
+
+}
Property changes on: trunk/sandbox/campussource-cse/src/test/java/de/campussource/cse/CamelTest.java
___________________________________________________________________
Added: svn:mime-type
+ text/plain
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
