Bots From Extension: rabbitmq
RabbitMQ - Read and Write data to RabbitMQ stream
This extension provides 2 bots.
Bot @rabbitmq:read-stream
Bot Position In Pipeline: Source
Reads message(s) from RabbitMQ Queue
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
| Parameter Name | Type | Default Value | Description |
|---|---|---|---|
| queue* | Text | Specify RabbitMQ Queue name | |
| max_messages | Text | Maximum number of messages to collect before terminating the collection. Default will keep streaming infinitely. |
|
| batch_wait_time | Text | 1.0 | Number of seconds to wait before returning the messages. |
| batch_count | Text | 100 | Maximum number of messages in a batch. |
| lazy_commit | Text | no | Commit the messages only after the pipeline has completed processing them. |
Bot @rabbitmq:write-stream
Bot Position In Pipeline: Sink
Writes message(s) to RabbitM Queue
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
| Parameter Name | Type | Default Value | Description |
|---|---|---|---|
| queue* | Text | Specify RabbitMQ Queue name | |
| exchange | Text | Specify RabbitMQ Exchange. By default, default exchange will be used. Supported are direct, topic, headers and fanout |
|
| create_if_not_exists | Text | no | Create the queue if it doesnot exist. |