Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-1931 Add camel example

This commit is contained in:
Justin Bertram 2017-11-17 12:29:48 -06:00 committed by Clebert Suconic
parent e2e1034bdb
commit 3b6c010739
10 changed files with 477 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
docs/user-manual/en/examples.md
View File

@ -270,6 +270,11 @@ A `QueueBrowser` is used to look at messages on the queue without removing
them. It can scan the entire content of a queue or only messages matching a
message selector.
## Camel
The `camel` example demonstrates how to build and deploy a Camel route to the
broker using a web application archive (i.e. `war` file).
## Client Kickoff
The `client-kickoff` example shows how to terminate client connections given an

132
examples/features/standard/camel/camel-broker/pom.xml Normal file
View File

@ -0,0 +1,132 @@
<?xml version='1.0'?>
<!--
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.activemq.examples.broker.camel</groupId>
<artifactId>camel</artifactId>
<version>2.7.0-SNAPSHOT</version>
</parent>
<artifactId>camel-broker</artifactId>
<packaging>jar</packaging>
<name>ActiveMQ Artemis Camel Broker</name>
<properties>
<activemq.basedir>${project.basedir}/../../../../..</activemq.basedir>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>artemis-server</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.activemq.examples.broker.camel</groupId>
<artifactId>camel-war</artifactId>
<version>${project.version}</version>
<type>war</type>
</dependency>
<dependency>
<groupId>org.apache.geronimo.specs</groupId>
<artifactId>geronimo-jms_2.0_spec</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.activemq</groupId>
<artifactId>artemis-maven-plugin</artifactId>
<version>${project.version}</version>
<executions>
<execution>
<id>create0</id>
<goals>
<goal>create</goal>
</goals>
<configuration>
<webList>
<!-- pull in the war file from the camel-war maven module and put it into the "web" directory
so it will be deployed when the broker starts -->
<arg>org.apache.activemq.examples.broker.camel:camel-war:war:${project.version}</arg>
</webList>
<replacePairs>
<arg>WARFILE</arg>
<arg>camel-war-${project.version}.war</arg>
</replacePairs>
<ignore>${noServer}</ignore>
<instance>${basedir}/target/server0</instance>
<configuration>${basedir}/target/classes/activemq/server0</configuration>
</configuration>
</execution>
<execution>
<id>start0</id>
<goals>
<goal>cli</goal>
</goals>
<configuration>
<ignore>${noServer}</ignore>
<spawn>true</spawn>
<location>${basedir}/target/server0</location>
<testURI>tcp://localhost:61616</testURI>
<args>
<param>run</param>
</args>
<name>server0</name>
</configuration>
</execution>
<execution>
<id>runClient</id>
<goals>
<goal>runClient</goal>
</goals>
<configuration>
<clientClass>org.apache.activemq.artemis.jms.example.CamelExample</clientClass>
</configuration>
</execution>
<execution>
<id>stop0</id>
<goals>
<goal>cli</goal>
</goals>
<configuration>
<ignore>${noServer}</ignore>
<location>${basedir}/target/server0</location>
<args>
<param>stop</param>
</args>
</configuration>
</execution>
</executions>
<dependencies>
<dependency>
<groupId>org.apache.activemq.examples.broker.camel</groupId>
<artifactId>camel-broker</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
</plugin>
</plugins>
</build>
</project>

102
examples/features/standard/camel/camel-broker/src/main/java/org/apache/activemq/artemis/jms/example/CamelExample.java Normal file
View File

@ -0,0 +1,102 @@
/*
* 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.activemq.artemis.jms.example;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.naming.InitialContext;
import java.util.Hashtable;
public class CamelExample {
public static void main(final String[] args) throws Exception {
Connection connection = null;
InitialContext ic = null;
try {
// Step 1. - we create an initial context for looking up JNDI
Hashtable<String, Object> properties = new Hashtable<>();
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
properties.put("connectionFactory.ConnectionFactory", "tcp://127.0.0.1:61616");
properties.put("queue.queue/sausage-factory", "sausage-factory");
properties.put("queue.queue/mincing-machine", "mincing-machine");
ic = new InitialContext(properties);
// Step 2. - we look up the sausage-factory queue from node 0
Queue sausageFactory = (Queue) ic.lookup("queue/sausage-factory");
Queue mincingMachine = (Queue) ic.lookup("queue/mincing-machine");
// Step 3. - we look up a JMS ConnectionFactory object from node 0
ConnectionFactory cf = (ConnectionFactory) ic.lookup("ConnectionFactory");
// Step 4. We create a JMS Connection connection which is a connection to server 0
connection = cf.createConnection();
// Step 5. We create a JMS Session on server 0
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// Step 6. We start the connection to ensure delivery occurs on them
connection.start();
// Step 7. We create JMS MessageConsumer object
MessageConsumer consumer = session.createConsumer(mincingMachine);
// Step 8. We create a JMS MessageProducer object
MessageProducer producer = session.createProducer(sausageFactory);
// Step 9. We create and send a message to the sausage-factory
Message message = session.createMessage();
producer.send(message);
System.out.println("Sent message to sausage-factory");
// Step 10. - we successfully receive the message from the mincing-machine.
Message receivedMessage = consumer.receive(5000);
if (receivedMessage == null) {
throw new IllegalStateException();
}
System.out.println("Received message from mincing-machine");
} finally {
// Step 15. Be sure to close our resources!
if (connection != null) {
connection.close();
}
if (ic != null) {
ic.close();
}
}
}
}

30
examples/features/standard/camel/camel-broker/src/main/resources/activemq/server0/bootstrap.xml Normal file
View File

@ -0,0 +1,30 @@
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<!--
~ 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.
-->
<broker xmlns="http://activemq.org/schema">
<jaas-security domain="activemq"/>
<server configuration="${artemis.URI.instance}/etc/broker.xml"/>
<web bind="http://localhost:8080" path="web">
<!-- ${war} is defined in the example's pom.xml -->
<app url="camel" war="WARFILE"/>
</web>
</broker>

76
examples/features/standard/camel/camel-war/pom.xml Normal file
View File

@ -0,0 +1,76 @@
<?xml version='1.0'?>
<!--
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.activemq.examples.broker.camel</groupId>
<artifactId>camel</artifactId>
<version>2.7.0-SNAPSHOT</version>
</parent>
<artifactId>camel-war</artifactId>
<packaging>war</packaging>
<name>ActiveMQ Artemis Camel WAR Application</name>
<properties>
<activemq.basedir>${project.basedir}/../../../../..</activemq.basedir>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring</artifactId>
<version>2.20.0</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-jms</artifactId>
<version>2.20.0</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
<exclusion>
<groupId>org.apache.geronimo.specs</groupId>
<artifactId>geronimo-jms_2.0_spec</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
</project>

45
examples/features/standard/camel/camel-war/src/main/webapp/WEB-INF/applicationContext.xml Normal file
View File

@ -0,0 +1,45 @@
<?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.
-->
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd">
<bean id="artemisConnectionFactory" class="org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory">
<constructor-arg index="0" value="tcp://localhost:61616"/>
</bean>
<bean id="artemisConfig" class="org.apache.camel.component.jms.JmsConfiguration">
<property name="connectionFactory" ref="artemisConnectionFactory"/>
<property name="concurrentConsumers" value="10"/>
</bean>
<bean id="artemis" class="org.apache.camel.component.jms.JmsComponent">
<property name="configuration" ref="artemisConfig"/>
</bean>
<camelContext id="bridgeContext" trace="false" xmlns="http://camel.apache.org/schema/spring">
<route id="exampleRoute">
<from uri="artemis:queue:sausage-factory"/>
<to uri="artemis:queue:mincing-machine"/>
</route>
</camelContext>
</beans>

27
examples/features/standard/camel/camel-war/src/main/webapp/WEB-INF/web.xml Normal file
View File

@ -0,0 +1,27 @@
<?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.
-->
<web-app xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
version="2.5">
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
</web-app>

43
examples/features/standard/camel/pom.xml Normal file
View File

@ -0,0 +1,43 @@
<?xml version='1.0'?>
<!--
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.activemq.examples.broker</groupId>
<artifactId>jms-examples</artifactId>
<version>2.7.0-SNAPSHOT</version>
</parent>
<groupId>org.apache.activemq.examples.broker.camel</groupId>
<artifactId>camel</artifactId>
<packaging>pom</packaging>
<name>ActiveMQ Artemis Camel Example</name>
<properties>
<activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
</properties>
<modules>
<module>camel-war</module>
<module>camel-broker</module>
</modules>
</project>

15
examples/features/standard/camel/readme.md Normal file
View File

@ -0,0 +1,15 @@
# Camel Example
To run the example, simply type **mvn verify** from this directory, or **mvn -PnoServer verify** if you want to start and create the broker manually.
This example contains 2 different Maven modules:
1) `camel-broker` The module responsible for creating the broker, deploying the WAR-based Camel application, and running the client.
2) `camel-war` The module used to build the WAR-based Camel application.
The overall goal of this example is to demonstrate how to build and deploy a Camel route to the broker.
The client itself is essentially the same as the one in the `core-bridge` example except there is only 1 broker in this
example rather than 2. A Camel route defined in the WAR is responsible for moving messages between 2 queues. The client
sends a message to one queue, the Camel route moves that message to a second queue, and then the client reads that
message from the second queue.

2
examples/features/standard/pom.xml
View File

@ -44,6 +44,7 @@ under the License.
<module>auto-closeable</module>
<module>browser</module>
<module>broker-plugin</module>
<module>camel</module>
<module>cdi</module>
<module>client-kickoff</module>
<module>completion-listener</module>
@ -114,6 +115,7 @@ under the License.
<module>auto-closeable</module>
<module>browser</module>
<module>broker-plugin</module>
<module>camel</module>
<module>cdi</module>
<module>client-kickoff</module>
<module>completion-listener</module>