RabbitMQ Subscribe from Queue#
The RabbitMQ Subscribe from Queue task will create a subscription to a particular Queue. If the request awaits for a reply it will create an execution context to acknowledge. This task is paired with the RabbitMQ Acknowledge task to return an acknowledge.
Inputs#
| Name | Data Type | Description |
|---|---|---|
| Queue Name | String | The Queue name to send the message. |
| Delete on unsubscribe | Boolean | Should delete Queue on unsubscribe. |
| ReplyTimeout | Integer | Amount of time allowed to wait for a reply before issuing a timeout. |
| Enable/Disable | Boolean | Activates the subscription. |
Outputs#
| Name | Data Type | Description |
|---|---|---|
| Topic | String | The topic received. |
| rawMessage | any | The raw message received. |
| message | String | The message content received. |
| Success | Boolean | If there was no problem emits a true. |
| Error | Error | Error that occurred during the processing of this task. |
Settings#
| Name | Data Type | Default | Description |
|---|---|---|---|
| Queue Name | String | defaultQueue | The exchange Name to publish to. |
| Auto Ack | Boolean | true | Should an automatic acknowledge be sent upon receiving a message. |
| Delete on unsubscribe | Boolean | false | Should the exchange (and associated queue) be deleted on un-subscription. |
| Reply Timeout | Integer | 60000 | Amount of time allowed to wait for a reply before issuing a timeout. |
Behavior#
The RabbitMQ Subscribe from Queue task will create a subscription for a specific Queue and create a context for the message. If the request awaits for an acknowledge it will expect to receive an execution from the RabbitMQ Acknowledge task in the allotted time of the ReplyTimeout.
Remarks#
- This task allows the user to explicitly define the deletion of the queue related with the subscription. This might be useful when queue is only being used by this task, this way when the un-subscription occurs no durable queues stay on the rabbitMQ.