Red Hat Summit Red Hat SummitSupportKonsoleEntwicklerDemo startenKontakt

Dieser Inhalt ist in der von Ihnen ausgewählten Sprache nicht verfügbar.

5.2. Tutorial III: Camel ActiveMQ Component

Overview
Link kopieren

This tutorial explains how to define a route featuring an Apache ActiveMQ endpoint, where the route is defined using Spring XML and then deployed into the OSGi container as a bundle. The implementation of the route is simple: it generates a stream of messages using a timer and the messages are then sent to a JMS queue in an Apache ActiveMQ broker.
The key feature of this example is that the Apache ActiveMQ endpoint at the end of the route must be configured to open a secure connection to the broker. In order to define a secure endpoint, the Apache ActiveMQ component is customized to enable both SSL security and JAAS security in the underlying JMS connection factory.

Prerequisites
Link kopieren

This tutorial part builds on Section 4.1, “Tutorial I: SSL/TLS Security” and Section 4.3, “Tutorial II: JAAS Authentication”. All of the prerequisites from the section called “Prerequisites” apply here and you must complete the previous tutorial parts before proceeding.

Tutorial steps
Link kopieren

To define a route, which is deployed in the OSGi container and can communicate with a secure Apache ActiveMQ endpoint, perform the following steps:
  1. the section called “Add Maven dependency”.
  2. the section called “Add package imports”.
  3. the section called “Configure the Camel ActiveMQ component”.
  4. the section called “Configure the Camel route”.
  5. the section called “Build the bundle”.
  6. the section called “Install the camel-activemq feature”.
  7. the section called “Deploy the bundle”.
  8. the section called “Monitor the queue contents”.
  9. the section called “Uninstall the broker bundle”.

Add Maven dependency
Link kopieren

Edit the pom.xml file in your Maven project and add the following dependency as a child of the dependencies element: 
  <dependencies>
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-core</artifactId>
      <version>5.8.0.redhat-60024</version> <scope>provided</scope> </dependency>
    ...
  </dependencies>
Copy to Clipboard Toggle word wrap

Add package imports
Link kopieren

In order to build the Apache Camel route in Maven, you need to add the following package imports to the configuration of the maven-bundle-plugin plug-in: 
org.apache.activemq.pool
org.apache.activemq.camel.component,
org.apache.camel.component.jms
Copy to Clipboard Toggle word wrap
These imports are needed, because the Maven bundle plug-in is not able to figure out all of the imports required by beans created in the Spring configuration file.
Edit the pom.xml file in your Maven project and add the preceding package imports, so that the maven-bundle-plugin configuration looks like the following: 
<plugins>
  <plugin>
    <groupId>org.apache.felix</groupId>
    <artifactId>maven-bundle-plugin</artifactId>
    <extensions>true</extensions>
    <configuration>
      <instructions>
        <Bundle-SymbolicName>${project.artifactId}</Bundle-SymbolicName>
	        <Import-Package>org.apache.activemq.xbean,
                            org.apache.activemq.spring,
                            org.apache.activemq.broker,
                            org.apache.activemq.security,
                            org.apache.activemq.jaas,
                            org.apache.activemq.pool,
                            org.apache.activemq.camel.component,
                            org.apache.camel.component.jms,
                            *</Import-Package>
      </instructions>
    </configuration>
  </plugin>
  ...
</plugins>
Copy to Clipboard Toggle word wrap

Configure the Camel ActiveMQ component
Link kopieren

Edit the broker-spring.xml file in the src/main/resources/META-INF/spring directory of your Maven project and add the following bean definitions, which configure the Camel ActiveMQ component: 
<?xml version="1.0" encoding="UTF-8"?>
<beans ... >
  ...
  <!--
    Configure the activemq component:
  -->
  <bean id="jmsConnectionFactory"
        class="org.apache.activemq.ActiveMQSslConnectionFactory">
    <property name="brokerURL" value="ssl://localhost:61001" />
    <property name="userName" value="smx"/>
    <property name="password" value="smx"/>
    <property name="trustStore" value="/conf/client.ts"/>
    <property name="trustStorePassword" value="password"/>
  </bean>

  <bean id="pooledConnectionFactory"
        class="org.apache.activemq.pool.PooledConnectionFactory">
    <property name="maxConnections" value="8" />
    <property name="maximumActive" value="500" />
    <property name="connectionFactory" ref="jmsConnectionFactory" />
  </bean>

  <bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory"/>
    <property name="transacted" value="false"/>
    <property name="concurrentConsumers" value="10"/>
  </bean>

  <bean id="activemqs"
        class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="configuration" ref="jmsConfig"/>
  </bean>

</beans>
Copy to Clipboard Toggle word wrap
This configuration defines the secure activemqs component, which you can now use to define endpoints in your Apache Camel routes. The activemqs bean references jmsConfig, which configures the the component. The jmsConfig bean in turn references a chain of JMS connection factories: the pooled connection factory wrapper, pooledConnectionFactory, which is important for performance; and the secure connection factory, jmsConnectionFactory, which is capable of creating secure connections to the broker.

Configure the Camel route
Link kopieren

Configure a Apache Camel route that generates messages using a timer endpoint and then sends the generated messages to the security.test queue on the secure broker. For this route, you need to use the secure activemqs component to define the endpoint that connects to the broker.
Edit the broker-spring.xml file in the src/main/resources/META-INF/spring directory of your Maven project and add the following camelContext element, which contains the route definition: 
<?xml version="1.0" encoding="UTF-8"?>
<beans ...>
  ...
  <camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
      <from uri="timer://myTimer?fixedRate=true&amp;period=5000"/>
      <transform><constant>Hello world!</constant></transform>
      <to uri="activemqs:security.test"/>
    </route>
  </camelContext>
  ...
</beans>
Copy to Clipboard Toggle word wrap
You must also add the location of the Apache Camel XML schema to the xsi:schemaLocation attribute, as highlighted in the following example: 
<?xml version="1.0" encoding="UTF-8"?>
<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-3.0.xsd
       http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.4.0.xsd
       http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
    ...
Copy to Clipboard Toggle word wrap

Build the bundle
Link kopieren

Use Maven to build the bundle. Open a command prompt, switch the current directory to ProjectDir/esb-security, and then enter the following command: 
mvn clean install
Copy to Clipboard Toggle word wrap

Install the camel-activemq feature
Link kopieren

If you have not already done so, start up the Apache ServiceMix console (and container instance) by entering the following command in a new command prompt: 
servicemix
Copy to Clipboard Toggle word wrap
The camel-activemq feature, which defines the bundles required for the Camel ActiveMQ component, is not installed by default. To install the camel-activemq feature, enter the following console command: 
JBossFuse:karaf@root> features:install camel-activemq
Copy to Clipboard Toggle word wrap

Deploy the bundle
Link kopieren

To deploy and activate the broker bundle, enter the following console command: 
JBossFuse:karaf@root> osgi:install -s mvn:org.jbossfuse.example/esb-security
Copy to Clipboard Toggle word wrap

Monitor the queue contents
Link kopieren

You can monitor the contents of the security.test queue using a JMX management tool, such as Java's jconsole. Open a command prompt and enter the following command: 
jconsole
Copy to Clipboard Toggle word wrap
A JConsole: Connect to Agent dialog opens. From the Local tab, select the org.apache.karaf.main.Main entry and click Connect. The main JConsole window appears. Select the MBeans tab and then drill down to org.apache.activemq|Queue|security.test, as shown in the screenshot below. From the EnqueueCount bean attribute, you can see how many messages have been sent to the queue. By clicking Refresh to update the bean attributes, you can see that messages are arriving at the rate of one every five seconds.
View larger image

Uninstall the broker bundle
Link kopieren

To uninstall the broker bundle, you need to know its bundle ID, BundleID, in which case you can uninstall it by entering the following console command: 
JBossFuse:karaf@root> osgi:uninstall BundleID
Copy to Clipboard Toggle word wrap
Nach oben
Red Hat logoGithubredditYoutubeTwitter

Lernen

Testen, kaufen und verkaufen

Communitys

Über Red Hat Dokumentation

Wir helfen Red Hat Benutzern, mit unseren Produkten und Diensten innovativ zu sein und ihre Ziele zu erreichen – mit Inhalten, denen sie vertrauen können. Entdecken Sie unsere neuesten Updates.

Mehr Inklusion in Open Source

Red Hat hat sich verpflichtet, problematische Sprache in unserem Code, unserer Dokumentation und unseren Web-Eigenschaften zu ersetzen. Weitere Einzelheiten finden Sie in Red Hat Blog.

Über Red Hat

Wir liefern gehärtete Lösungen, die es Unternehmen leichter machen, plattform- und umgebungsübergreifend zu arbeiten, vom zentralen Rechenzentrum bis zum Netzwerkrand.

Theme

© 2025 Red Hat