...
After dragging this unit into the Flow canvas, double-click it to access its configuration options. The following table describes the configuration options of this unit:
Tab | Field | Description | |
---|---|---|---|
General | Name | Enter a name for the unit. It must start with a letter, and cannot contain spaces. Only letters, numbers, and underscores are allowed. | |
Description | Enter a description detailing the scope of the unit. | ||
Status queues | Queue | Click the plus icon to add queue settings. You can collapse and expand the queues using the icon, reorder using the arrows, or delete using the X icon. You can also reorder the fields using drag and drop. | |
Key | Enter the key to identify a queue within its namespace | ||
Source | The source of the messages (a queue or an exchange). If an exchange is given, a temporary queue will be created. | ||
Is exchange | Whether the selected source is an exchange (true) or a queue (false). | ||
Routing key | Enter the label to describe the message. Only applies when the source is an exchange. | ||
Host | Enter the host to use for establishing the initial connection to RabbitMQ. | ||
Virtual host | Enter the name of the virtual host used to configure RabbitMQ instances. | ||
Port | Enter the name of the port used for establishing a connection to RabbitMQ. | ||
Username | Specify the client name to access RabbitMQ. | ||
Password | Enter the password requested to access RabbitMQ. | ||
Connection timeout | The maximum amount of time (in milliseconds) to maintain the connection. | ||
Requested heartbeat | Indicate how often (in milliseconds) to send signals to indicate normal operation in order to maintain the connection alive. Zero for no heartbeat. | ||
Auto ack | Whether to acknowledge queue items after extracting them from the queue. If false, you will have to send acks later using an mq.RabbitAck unit. | ||
Charset | Indicate the encoding system to use for the message text. | ||
Input events | Key | Enter the name of an input event field containing a key setting. | |
Host | Enter the name of an input event field containing the host setting. | ||
Virtual host | Enter the name of an input event field containing virtual host setting. | ||
Port | Enter the name of an input event field containing the port setting. | ||
Username | Enter the name of an input event field containing the username setting. | ||
Password | Enter the name of an input event field containing password setting. | ||
Connection timeout | Enter the name of an input event field containing the connection timeout setting. | ||
Requested heartbeat | Enter the name of an input event field containing the requested heartbeat setting. | ||
Charset | Enter the name of an input event field containing the charset setting. | ||
Source | Enter the name of an input event field containing the source setting. | ||
Is exchange | Enter the name of an input event field containing the is exchange setting. | ||
Routing key | Enter the name of an input event field containing the routing key setting. | ||
Auto Ack | Enter the name of an input event field containing the autoAck setting. | ||
Defaults | The fields in this tab are identical the fixed and dynamic queue settings. Here you can enter default values to be applied to both. | ||
Output events | Channel | Enter a name for the output event field containing the channel. | |
Delivery tag | Enter a name for the output event field containing the delivery tag. | ||
Exchange | Enter a name for the output event field containing the exchange. | ||
Routing key | Enter a name for the output event field containing the routing key setting. | ||
Body | Enter a name for the output event field containing the body of the message. |
Input ports
Port | Description |
---|---|
add | Input events to request a new queue to be added. Must have at least a field specifying the queue key. |
remove | Input events to remove a previously added queue. Must have at least a field specifying the queue key. |
removeAll | Input events to remove all previously added queues. No fields needed. |
Output ports
Port | Description |
---|---|
data | Output events for successful RabbitMQ messages. The structure is defined by the output event settings. |
error | Output events for failed RabbitMQ messages, enriched with standard error fields. |
done | Output events for successful queue manipulation actions, enriched with an action field specifying the action performed. |
fail | Output events for failed queue manipulation actions, enriched with an action field and standard error fields. |