camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r649916 - in /activemq/camel/trunk/examples/camel-example-spring-jms: ./ src/ src/main/ src/main/java/ src/main/java/org/ src/main/java/org/example/ src/main/java/org/example/client/ src/main/java/org/example/server/ src/main/resources/ src...
Date Sun, 20 Apr 2008 12:47:26 GMT
Author: ningjiang
Date: Sun Apr 20 05:47:22 2008
New Revision: 649916

URL: http://svn.apache.org/viewvc?rev=649916&view=rev
Log:
CAMEL-471 added the tutorial example into the example directory

Added:
    activemq/camel/trunk/examples/camel-example-spring-jms/   (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/pom.xml   (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClient.java
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClientRemoting.java
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/CamelServer.java
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/JmsBroker.java
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Multiplier.java
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/ServerRoutes.java
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Treble.java
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/camel-server.xml
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client-remoting.xml
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client.xml
  (with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/log4j.xml  
(with props)
    activemq/camel/trunk/examples/camel-example-spring-jms/src/test/
    activemq/camel/trunk/examples/camel-example-spring-jms/src/test/java/

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Apr 20 05:47:22 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes

Added: activemq/camel/trunk/examples/camel-example-spring-jms/pom.xml
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/pom.xml?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/pom.xml (added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/pom.xml Sun Apr 20 05:47:22 2008
@@ -0,0 +1,83 @@
+<?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.camel</groupId>
+    <artifactId>examples</artifactId>
+    <version>1.4-SNAPSHOT</version>
+  </parent>
+  
+  <artifactId>camel-example-spring-jms</artifactId>
+  <name>Camel :: Example :: Spring :: JMS </name>
+  <description>An example using Spring XML to talk to the JMS server  </description>
+ 
+ <dependencies>
+    <dependency>
+      <groupId>log4j</groupId>
+	<artifactId>log4j</artifactId>
+      <version>1.2.14</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.activemq</groupId>
+      <artifactId>activemq-all</artifactId>
+      <version>5.0.0</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-jms</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-spring</artifactId>
+    </dependency>
+    
+    <!-- for testing -->
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+  
+  <build>
+    <plugins>
+      <!-- Allows the routes to be run via 'mvn camel:run' -->
+      <plugin>
+        <groupId>org.apache.camel</groupId>
+        <artifactId>camel-maven-plugin</artifactId>
+      </plugin>      
+    </plugins>
+  </build>
+
+  <reporting>
+    <plugins>
+      <!-- Generates nice PNG / SVG diagrams from our routes -->
+      <plugin>
+        <groupId>org.apache.camel</groupId>
+        <artifactId>camel-maven-plugin</artifactId>
+      </plugin>
+    </plugins>
+  </reporting>
+</project>

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/pom.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/pom.xml
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/pom.xml
------------------------------------------------------------------------------
    svn:mime-type = text/xml

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClient.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClient.java?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClient.java
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClient.java
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,47 @@
+/**
+ * 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.example.client;
+
+import org.apache.camel.CamelTemplate;
+import org.apache.camel.ExchangePattern;
+import org.apache.camel.component.jms.JmsExchange;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+/**
+ * Requires that the JMS broker is running, as well as CamelServer
+ *
+ * @author martin.gilday
+ */
+public final class CamelClient {
+
+    private CamelClient() {
+        // The main class
+    }
+
+    public static void main(final String[] args) {
+
+        ApplicationContext context = new ClassPathXmlApplicationContext("camel-client.xml");
+        CamelTemplate<JmsExchange> camelTemplate = (CamelTemplate)context.getBean("camelTemplate");
+
+        int response = (Integer)camelTemplate.sendBody("jms:queue:numbers", ExchangePattern.InOut,
22);
+        System.out.println("Invoking the multiply with 22, the result is " + response);
+        System.exit(0);
+
+    }
+
+}

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClient.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClient.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClientRemoting.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClientRemoting.java?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClientRemoting.java
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClientRemoting.java
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,44 @@
+/**
+ * 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.example.client;
+
+import org.example.server.Multiplier;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+/**
+ * Requires that the JMS broker is running, as well as CamelServer
+ *
+ * @author martin.gilday
+ */
+public final class CamelClientRemoting {
+
+    private CamelClientRemoting() {
+        // the main class
+    }
+
+    public static void main(final String[] args) {
+
+        ApplicationContext context = new ClassPathXmlApplicationContext("camel-client-remoting.xml");
+        Multiplier multiplier = (Multiplier)context.getBean("multiplierProxy");
+        int response = multiplier.multiply(22);
+        System.out.println("Invoking the multiply with 22, the result is " + response);
+        System.exit(0);
+
+    }
+
+}

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClientRemoting.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/client/CamelClientRemoting.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/CamelServer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/CamelServer.java?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/CamelServer.java
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/CamelServer.java
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,54 @@
+/**
+ * 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.example.server;
+
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+/**
+ * @author martin.gilday
+ */
+public final class CamelServer {
+    private CamelServer() {
+        // the main class
+    }
+
+    /**
+     * @param args
+     */
+    public static void main(final String[] args) {
+        JmsBroker broker = new JmsBroker();
+
+        try {
+            broker.start();
+            ApplicationContext context = new ClassPathXmlApplicationContext("META-INF/spring/camel-server.xml");
+            Thread.sleep(5 * 60 * 1000);
+        } catch (Exception e) {
+            // get the exception
+            e.printStackTrace();
+        } finally {
+            try {
+                broker.stop();
+            } catch (Exception e) {
+                // do nothing here
+            }
+            System.exit(0);
+        }
+
+    }
+
+}

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/CamelServer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/CamelServer.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/JmsBroker.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/JmsBroker.java?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/JmsBroker.java
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/JmsBroker.java
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,104 @@
+/**
+ * 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.example.server;
+
+import java.io.File;
+
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
+
+public final class JmsBroker {
+    JMSEmbeddedBroker jmsBrokerThread;
+    String jmsBrokerUrl = "tcp://localhost:61616";
+    String activeMQStorageDir;
+    public JmsBroker() {
+    }
+
+    public JmsBroker(String url) {
+        jmsBrokerUrl = url;
+    }
+    
+    public void start() throws Exception {
+        jmsBrokerThread = new JMSEmbeddedBroker(jmsBrokerUrl);
+        jmsBrokerThread.startBroker();
+    }
+    
+    public void stop() throws Exception {
+        synchronized (this) {
+            jmsBrokerThread.shutdownBroker = true;
+        }
+        if (jmsBrokerThread != null) {
+            jmsBrokerThread.join();
+        }
+        
+        jmsBrokerThread = null;
+    }
+    
+    class JMSEmbeddedBroker extends Thread {
+        boolean shutdownBroker;
+        final String brokerUrl;
+        Exception exception;
+        
+        
+        public JMSEmbeddedBroker(String url) {
+            brokerUrl = url;
+        }
+        
+        public void startBroker() throws Exception {
+            synchronized (this) {
+                super.start();
+                try {
+                    wait();
+                    if (exception != null) {
+                        throw exception;
+                    }
+                } catch (InterruptedException ex) {
+                    ex.printStackTrace();
+                }
+            }
+        }
+        
+        public void run() {
+            try {  
+                //ContainerWapper container;
+                BrokerService broker = new BrokerService();
+                synchronized (this) {                                     
+                    broker.setPersistenceAdapter(new MemoryPersistenceAdapter());       
            
+                    broker.setTmpDataDirectory(new File("./target"));
+                    broker.addConnector(brokerUrl);
+                    broker.start();
+                    Thread.sleep(200);
+                    notifyAll();
+                }
+                synchronized (this) {
+                    while (!shutdownBroker) {
+                        wait(1000);
+                    }
+                }                
+                broker.stop();              
+                broker = null;                
+            } catch (Exception e) {
+                exception = e;
+                e.printStackTrace();
+            }
+        }
+        
+       
+    }
+}
+

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/JmsBroker.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/JmsBroker.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Multiplier.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Multiplier.java?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Multiplier.java
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Multiplier.java
Sun Apr 20 05:47:22 2008
@@ -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.example.server;
+
+/**
+ * @author martin.gilday
+ */
+public interface Multiplier {
+
+    /**
+     * Multiplies the given number by a pre-defined constant.
+     *
+     * @param originalNumber The number to be multiplied
+     * @return The result of the multiplication
+     */
+    int multiply(int originalNumber);
+
+}

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Multiplier.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Multiplier.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/ServerRoutes.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/ServerRoutes.java?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/ServerRoutes.java
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/ServerRoutes.java
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,36 @@
+/**
+ * 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.example.server;
+
+import org.apache.camel.builder.RouteBuilder;
+
+/**
+ * @author martin.gilday
+ */
+public class ServerRoutes extends RouteBuilder {
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see org.apache.camel.builder.RouteBuilder#configure()
+     */
+    @Override
+    public void configure() throws Exception {
+        from("jms:queue:numbers").beanRef("multiplier", "multiply");
+    }
+
+}

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/ServerRoutes.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/ServerRoutes.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Treble.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Treble.java?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Treble.java
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Treble.java
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,36 @@
+/**
+ * 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.example.server;
+
+import org.springframework.stereotype.Service;
+
+/**
+ * @author martin.gilday
+ */
+@Service(value = "multiplier")
+public class Treble implements Multiplier {
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see org.example.server.Multiplier#multiply(int)
+     */
+    public int multiply(final int originalNumber) {
+        return originalNumber * 3;
+    }
+
+}

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Treble.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/java/org/example/server/Treble.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/camel-server.xml
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/camel-server.xml?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/camel-server.xml
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/camel-server.xml
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,27 @@
+<?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:context="http://www.springframework.org/schema/context"
+	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.0.xsd
+		http://www.springframework.org/schema/context
+		http://schemas.leadx.com/spring/spring-context-2.5.xsd
+		http://activemq.apache.org/camel/schema/spring
+		http://activemq.apache.org/camel/schema/spring/camel-spring-1.3.0.xsd">
+
+	<context:component-scan base-package="org.example.server" />
+
+	<camel:camelContext id="camel">
+		<camel:package>org.example.server</camel:package>
+	</camel:camelContext>
+
+	<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
+		<property name="connectionFactory">
+			<bean class="org.apache.activemq.ActiveMQConnectionFactory">
+				<property name="brokerURL" value="tcp://localhost:61616" />
+			</bean>
+		</property>
+	</bean>
+
+</beans>
\ No newline at end of file

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/camel-server.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/camel-server.xml
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/META-INF/spring/camel-server.xml
------------------------------------------------------------------------------
    svn:mime-type = text/xml

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client-remoting.xml
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client-remoting.xml?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client-remoting.xml
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client-remoting.xml
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,26 @@
+<?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: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.0.xsd
+		http://activemq.apache.org/camel/schema/spring
+		http://activemq.apache.org/camel/schema/spring/camel-spring-1.3-SNAPSHOT.xsd">
+
+	<camel:camelContext id="camel" />
+	<camel:template id="camelTemplate" />
+	
+	<camel:proxy
+		id="multiplierProxy"
+		serviceInterface="org.example.server.Multiplier"
+		serviceUrl="jms:queue:numbers"
+	/>
+	
+	<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
+		<property name="connectionFactory">
+			<bean class="org.apache.activemq.ActiveMQConnectionFactory">
+				<property name="brokerURL" value="tcp://localhost:61616" />
+			</bean>
+		</property>
+	</bean>
+</beans>
\ No newline at end of file

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client-remoting.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client-remoting.xml
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client-remoting.xml
------------------------------------------------------------------------------
    svn:mime-type = text/xml

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client.xml
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client.xml?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client.xml
(added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client.xml
Sun Apr 20 05:47:22 2008
@@ -0,0 +1,22 @@
+<?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: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.0.xsd
+		http://activemq.apache.org/camel/schema/spring
+		http://activemq.apache.org/camel/schema/spring/camel-spring-1.3-SNAPSHOT.xsd">
+
+	<camel:camelContext id="camel" />
+	<camel:template id="camelTemplate" />
+	
+	<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
+		<property name="connectionFactory">
+			<bean class="org.apache.activemq.ActiveMQConnectionFactory">
+				<property name="brokerURL" value="tcp://localhost:61616" />
+			</bean>
+		</property>
+	</bean>
+	
+
+</beans>
\ No newline at end of file

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client.xml
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/camel-client.xml
------------------------------------------------------------------------------
    svn:mime-type = text/xml

Added: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/log4j.xml
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/log4j.xml?rev=649916&view=auto
==============================================================================
--- activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/log4j.xml (added)
+++ activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/log4j.xml Sun
Apr 20 05:47:22 2008
@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
+<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/" debug="false">
+
+	<!-- ===================================================================== -->
+	<!--  APPENDERS			                                                   -->
+	<!-- ===================================================================== -->
+
+	<!-- SERVER CONSOLE LOG -->
+	<appender name="CONSOLE" class="org.apache.log4j.ConsoleAppender">
+		<param name="Target" value="System.out" />
+		<param name="Threshold" value="INFO" />
+		<layout class="org.apache.log4j.PatternLayout">
+			<param name="ConversionPattern" value="%d %-5p [%c] %m%n" />
+		</layout>
+	</appender>
+
+	<!-- ===================================================================== -->
+	<!--  CATEGORIES				                                           -->
+	<!-- ===================================================================== -->
+
+	<!-- LeadX -->
+	<logger name="org.example">
+		<level value="DEBUG"/>
+	</logger>
+
+	<!-- Libraries -->
+	<logger name="org.springframework">
+		<level value="INFO" />
+	</logger>
+	
+	<!-- ===================================================================== -->
+	<!--  ROOT				                                  		           -->
+	<!-- ===================================================================== -->
+
+	<root>
+		<appender-ref ref="CONSOLE" />
+	</root>
+
+</log4j:configuration>
\ No newline at end of file

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/log4j.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/log4j.xml
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: activemq/camel/trunk/examples/camel-example-spring-jms/src/main/resources/log4j.xml
------------------------------------------------------------------------------
    svn:mime-type = text/xml



Mime
View raw message