RabbitMQ Subscribe from Exchange#
The RabbitMQ Subscribe from Exchange task will create a subscription to a topic from a particular Exchange. 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 |
|---|---|---|
| Exchange Name | String | The exchange Name to subscribe to. |
| Exchange Type | String | The exchange type. |
| Key | String | The topic key to subscribe to. |
| Delete on unsubscribe | String | Should delete Exchange 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 | Values |
|---|---|---|---|---|
| Exchange Name | String | defaultExchange | The exchange Name to publish to. | |
| Exchange Type | enum | fanout | The exchange type to use. | direct, topic, headers, fanout, match orcustom |
| Custom Exchange Type | String | Custom Exchange type to use. Valid only when custom Exchange Type is selected. | ||
| Key | String | defaultKey | The topic key 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 Exchange task will create a subscription to a topic from a particular Exchange and create a context for the message. If the request awaits for a 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 exchange related with the subscription. This might be useful when exchange is only being used by this task, this way when the un-subscription occurs no durable exchanges stay on the rabbitMQ.
- The user should be aware that no validation is done on the deletion procedure, this means that if there are any other subscriptions on this exchange they will be lost upon deletion.