...
The amqp: component supports the AMQP 1.0 protocol using the JMS Client API of the Qpid project. In case you want to use AMQP 0.9 (in particular RabbitMQ) you might also be interested in the Camel RabbitMQ component. Please keep in mind that prior to the Camel 2.17.0 AMQP component supported AMQP 0.9 and above, however since Camel 2.17.0 it supports only AMQP 1.0.
Maven users will need to add the following dependency to their pom.xml
for this component:
Code Block | ||||
---|---|---|---|---|
| ||||
<dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-amqp</artifactId> <version>${camel.version}</version> <!-- use the same version as your Camel core version --> </dependency> |
...
You can specify all of the various configuration options of the JMS component after the destination name.
Usage
As AMQP component is inherited inherits from the JMS component, the . The usage of the former is almost identical to the latter:
Code Block | ||||
---|---|---|---|---|
| ||||
// Consuming from AMQP queue from("amqp:queue:incoming"). .to(...); // Sending message to the AMQP topic from(...). .to("amqp:topic:notify"); |
Configuring AMQP component
Starting from the Camel 2.16.1 you can also use the AMQPComponent#amqp10Component(String connectionURI)
factory method to return the AMQP 1.0 component with the pre-configured topic prefix:
...
Keep in mind that starting from the Camel 2.17 the 17 the AMQPComponent#amqp10Component(String connectionURI)
factory method has been deprecated on the behalf of the AMQPComponent#amqpComponent(String connectionURI)
:
Code Block | ||||
---|---|---|---|---|
| ||||
AMQPComponent amqp = AMQPComponent.amqpComponent("amqp://localhost:5672"); AMQPComponent authorizedAmqp = AMQPComponent.amqpComponent("amqp://localhost:5672", "user", "password"); |
Starting from Camel 2.17, in order to automatically configure the AMQP component, you can also add an instance of org.apache.camel.component.amqp.AMQPConnectionDetails
to the registry. For example for Spring Boot you just have to define bean:
...
You can also rely on the Camel properties to read the AMQP connection details. Factory The factory method AMQPConnectionDetails.discoverAMQP()
attempts to read Camel properties in a Kubernetes-like convention, just as demonstrated on the snippet below:
...
Like with any other JMS-based component, usually it's important to configure JMS connection factory. For example, you'd like to set your broker url URL or set proper connection credentials. Additionally, you would always want to set some kind of pooling (or caching) on the connection factory. An example of how to do both of these tasks is shown below.
Code Block | ||
---|---|---|
| ||
<bean id="jmsConnectionFactory" class="org.apache.qpid.jms.JmsConnectionFactory"> <property name="remoteURI" value="amqp://localhost:5672" /> <property name="username" value="admin"/> <property name="password" value="admin"/> </bean> <bean id="jmsCachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"> <property name="targetConnectionFactory" ref="jmsConnectionFactory" /> </bean> <bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration" > <property name="connectionFactory" ref="jmsCachingConnectionFactory" /> <property name="cacheLevelName" value="CACHE_CONSUMER" /> </bean> <bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent"> <property name="configuration" ref="jmsConfig" /> </bean> <camelContext xmlns="http://camel.apache.org/schema/blueprint" id="simple"> <route> <from uri="timer:simple?period=5000"/> <setBody> <simple>Hello World</simple> </setBody> <to uri="amqp:test"/> </route> </camelContext> |
Using amqp inside Karaf
If you want to To use the amqp
component inside the Karaf, there's already defined feature that will install all necessary bundles for you. All you need to do isKaraf use the predefined feature called camel-amqp
to install the necessary bundles.
Example:
Code Block | ||
---|---|---|
| ||
karaf@root()> repo-add camel karaf@root()> feature:install camel-amqp |
and the environment would be set.
Use the Additionally you can add camel-blueprint
or or camel-spring
features if you want to define your routes in those contexts.
...