RabbitMQ Sink
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Preview"
Send data to a RabbitMQ Broker.
Configuration Options
The following table summarizes the configuration options available for the spring-rabbitmq-sink
Kamelet:
Property | Name | Description | Type | Default | Example |
---|---|---|---|---|---|
Exchange name | Required The exchange name determines the exchange the queue is bound to. | string | |||
Server Address | Required RabbitMQ broker address. | string | localhost | ||
Server Port | Required RabbitMQ broker port. | integer | 5672 | ||
Auto Declare Producer | Specifies whether the producer should auto declare binding between exchange, queue and routing key when starting. | boolean | false | ||
Password | The password to access the RabbitMQ server. | string | |||
Protocol | The AMQP protocol to use. Enum values: * amqp * amqps | string | amqp | ||
Queue name | The queue to receive messages from. | string | |||
Routing Key | The routing key to use when binding a consumer queue to the exchange. | string | |||
Username | The username to access the RabbitMQ server. | string | |||
Virtual Host | The virtual host. | string | / |
Dependencies
At runtime, the spring-rabbitmq-sink
Kamelet relies upon the presence of the following dependencies:
-
camel:spring-rabbitmq
-
camel:kamelet
Camel JBang usage
Prerequisites
-
You’ve installed JBang.
-
You have executed the following command:
jbang app install camel@apache/camel
Supposing you have a file named route.yaml with this content:
- route:
from:
uri: "kamelet:timer-source"
parameters:
period: 10000
message: 'test'
steps:
- to:
uri: "kamelet:spring-rabbitmq-sink"
You can now run it directly through the following command
camel run route.yaml
Spring RabbitMQ Sink Kamelet Description
RabbitMQ Integration with Spring
This Kamelet integrates with RabbitMQ using Spring’s RabbitMQ support, providing advanced messaging capabilities with Spring Framework integration.
AMQP Protocol
RabbitMQ implements the Advanced Message Queuing Protocol (AMQP), providing:
-
Reliable message delivery
-
Message acknowledgments and confirmations
-
Dead letter queues for error handling
-
Message persistence and durability
Exchange and Routing
Supports RabbitMQ’s flexible routing mechanisms:
-
Direct, topic, fanout, and headers exchanges
-
Routing keys for message targeting
-
Queue binding and routing patterns
-
Message filtering and transformation
Spring Integration Benefits
Leverages Spring Framework features including:
-
Dependency injection and configuration
-
Transaction management
-
Error handling and retry mechanisms
-
Monitoring and management capabilities