This blog post briefly describes the Mule-RabbitMQ transport.
This transport can connect and establish exchanges in the Broker of RabbitMQ. In addition, it provides controls for sending and retrieving messages from the Broker using the appropriate endpoint. This transport currently supports Mule 2.x.
For information on how to download and install the Mule-RabbitMQ transport please go to the installation page.
The configuration page shows how to configure a Mule configuration file to enable the Mule-RabbitMQ transport.
To use the Mule-RabbitMQ transport in Mule, you need to complete the following steps:
- Import the schema.
- Configure the RabbitMQ connector.
- Configure Mule to use the RabbitMQ connector.
The connector defines several properties able to connect and establish exchanges in the Broker of RabbitMQ. Below is an example of how to configure an RMQ connector inside Mule:
An inbound endpoint is used to listen on a RabbitMQ queue. The address specifies which queue to listen to, the exchange it should relate to and the topic to use.
<rmq:inbound-endpoint address="rmq://exchange1:queue1/#" />
An outbound endpoint may be configured to specify which exchange messages are sent and which topic is used to filter these messages.
<rmq:outbound-endpoint address="rmq://exchange1/#" />