RabbitMQ Data Source
RabbitMQ Data Source reads messages from the RabbitMQ cluster using its exchanges and queues.
Configuring RabbitMQ Data Source
To add a RabbitMQ into your pipeline, drag the Data Source to the canvas and right click on it to configure.
Under the Schema Type tab, select Fetch From Source or Upload Data File.
| Field | Description |
|---|---|
| Connection Name | Connections are the Service identifiers. Select the connection name from the available list of connections, from where you would like to read the data. |
| Exchange Name | RMQ producers can only send messages to an exchange. The exchange pushes messages to queues from where consumers can read the message. |
| Exchange Type | Defines the functionality of the exchange i.e., how messages are routed through it. Exchange types: DIRECT, TOPIC and FANOUT. |
| Exchange Durable | Durable exchanges remain active when a server restarts. Non-durable exchanges (transient exchanges) are purged when a server restarts. |
| Exchange Auto Delete | If you set this to True, the exchange is deleted when all queues finish using it. |
| Routing Key | Identifies a key for redirecting messages to a specific topic. |
| Queue Name | Name of the queue where data will be published. |
| Queue Durable | Durable queues remain active when a server restarts. Non- durable queues (transient queues) are purged if/when a server restarts. |
| Queue Auto Delete | If set, the queue is deleted when all the consumers finish using it. |
| Add Configuration | To add additional custom RabbitMQ properties in key-value pair. |
Click on the Add Notes tab. Enter the notes in the space provided.
Click Done to save the configuration.
If you have any feedback on Gathr documentation, please email us!