Document toolboxDocument toolbox

Rabbit Sender

Description

This unit is a Processor type unit.

This unit writes into a RabbitMQ queue.
The destination can be a queue or an exchange. In both cases, if no RabbitMQ queue exists, it will be created.

An event comes in through the in port. When the event contains a field with the message to be written, the message is sent.
Successful input events are emitted through the done port without modification.
If an error occurs, the input event is enriched with standard error fields and emitted through the error port.</li>

Configuration

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:

TabFieldDescription
GeneralNameEnter a name for the unit. It must start with a letter, and cannot contain spaces. Only letters, numbers, and underscores are allowed.
Check configuration

Whether to connect to the destination when building the flow (true) or only when it has started (false).

HostEnter the host to use for establishing the initial connection to RabbitMQ.
Virtual hostEnter the name of the virtual host used to configure RabbitMQ instances.
PortEnter the name of the port used for establishing a connection to RabbitMQ.
UsernameSpecify the client name to access RabbitMQ.
PasswordEnter the password requested to access RabbitMQ.
Connection timeoutThe 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.

TargetThe name of the destination (queue or exchange).
Exchange typeWhether the selected source is an exchange or a queue (queue by default).
Routing keyEnter the label to describe the message. Only applies when the source is an exchange.
CharsetIndicate the encoding system to use for the message text.
Data fieldEnter the name of an input event field containing the message to be sent.

Input ports

PortDescription
inMust contain a field (defined by the dataField setting) containing the message to be sent.

Output ports

PortDescription
doneOutputs events that were successfully sent, without any modification.
error

Outputs events that were not successfully sent, enriched with standard error fields.