On this Page

Table of Contents

maxLevel	2
exclude	Older Versions\|Additional Resources\|Related Links\|Related Information

Snap type:

Write

Description:

This Snap writes messages from incoming binary document to a RabbitMQ destination queue.

Expected upstream Snaps: Any Snap with a binary output view can be connected upstream, e.g. CSV Formatter, JSON Formatter, XML Formatter, File Reader, etc.
Expected downstream Snaps: Downstream Snap is optional. Any Snap with a document input view can be connected downstream.
Expected input: Any binary data stream.
Expected output: The output view for this Snap is optional. The output view provides a document with information on the status of the message.

Prerequisites:

Access to the RabbitMQ Server.
Privileges to perform various actions on the Queues such as receive and send messages.

Support and limitations: Works in Ultra Pipelines.

Account:

This Snap uses account references created on the Accounts page of SnapLogic Manager to handle access to this endpoint. See Configuring RabbitMQ Accounts for information on setting up this type of account.

Views:

Input	This Snap has exactly one binary input view where it gets the binary data as a message to be written to the RabbitMQ destination queue.
Output	This Snap has at most one document output view.
Error	This Snap has at most one document error view and produces zero or more documents in the view.

Settings

Label

Required.The name for the Snap. You can modify this to be more specific, especially if you have more than one of the same Snap in your pipeline.

Exchange

Name of the RabbitMQ exchange used to push messages. If no exchange is specified, then RabbitMQ server's default exhange is used.

Example: Exchange1

Exchange type

The type of RabbitMQ exchange used to route the messages to the respective queues. Options available include:

direct: routes messages to queues based on the Routing Key
fanout: copies and routes a received message to all queues that are bound to it regardless of routing keys or pattern matching
headers: routes the messages based on arguments containing headers and optional values
topic: routes messages to queues based on matches between the Routing key and Queue

Durable exchange Whether or not the exchange is durable.

Queue

Name of the RabbitMQ queue to which messages have to be pushed. If the queue with specified name is not present on the RabbitMQ server, then a new queue is created and is bound to the exchange. If there is no Queue name available, the Snap creates a temporary Queue name and uses it until the execution and deletes as soon as the session expires.
If the Routing key is specified, then the queue is bound to the exchange with specified routing key and only the messages with specified routing key are pushed to the queue.

Example: Queue1

Default value: None

Create dynamic queue

If enabled the Snap generates a dynamic queue when the queue name is not provided. The Snap publishes the messages on the default (or specified) exchange and stores the messages in the dynamic queue until the session expires and the dynamic queue thus generated is deleted soon after.

When the dynamic queue is not selected with:

Queue name provided- the Snap publishes the messages in the specified exchange.
Queue name not provided- the Snap publishes the messages in the queue of the default exchange and stores the messages on the queue of that exchange type..

Default value: Selected

Auto delete

Select this check box to indicate that the RabbitMQ autoDelete property associated with the existing queue is set to true.

Default value: Deselected.

Routing Key

Conditional. Routing key to be used for binding the queue with the exchange. Supply the Routing key, when the Exchange type is direct and topic to route the message to queues.

Note

Routing key is mandatory is direct or topic exchange type is selected. Messages will not be routed otherwise and the following error will be displayed:

"<error message>"

x-match

Specifies the x-match value to be submitted for binding. The available options are:

any : If selected, even one matching header value is sufficient
all : If selected, mandates that all the values should match

Default value: all

Note
Select x-match only when the Exchange type is headers.

Wait for confirms timeout (ms)

Specifies the timeout in milliseconds. The Snap waits until the message published since the last call has been acknowledged or not by the broker or, until the given timeout elapses.

For example, If the time set is 1000 ms, if the Snap does not get the acknowledgement from the broker(Queue) for the published message until the given time, a timeout exception will be recorded.

Default value: 0

Header Properties

Specifies the header properties that will be used to bind the queue with an exchange as arguments.

Note
Configure Header properties only when the Exchange type is headers.

Only one header property can be specified in each row. Click to add a new row in this table and specify the values accordingly.

This fieldset comprises the following fields:

Header key
Header value

Header key

Specifies the name of the header that is being used for the binding.

Header value

Specifies the header value corresponding to the respective header key.

Message Properties

Specifies the properties to be set in RabbitMQ messages.

Only one property can be specified in each row. Click to add a new row in this table and specify the values accordingly.

This fieldset comprises the following fields:

Key
Value

Key

Specifies the name for the message property. The message properties that can be added are:

content-type
delivery-mode: 1 (non-persistent), 2 (persistent)
expiration
priority
correlation-ID
redelivered

Refer this link for the additional information:
https://www.rabbitmq.com/amqp-0-9-1-reference.html#class.basic

Value Specifies the value for the message property.

Argument properties

Specifies the custom argument properties to ensure all declarations for the queues use the same configuration/options/arguments.

Only one argument can be specified in each row. Click to add a new row in this table and specify the values accordingly.

This fieldset comprises the following fields:

Argument key
Argument value

Argument key

Specifies the name of the argument used for declaration. See Optional Arguments in RabbitMQ documentation for more information.

Example: x-max-len-bytes, x-max-priority, x-queue-type

Default value: None.

Argument value

Specifies the value corresponding to the argument key.

Info
To publish messages to the quorum queue, specify Argument key as x-queue-type and Argument value as quorum.

Example: 1048576, 2, quorum

Default value: None.

Maximum connection attempts

The maximum number of connection attempts in case of a connection failure. The Snap retries for the configured number of attempts for establishing the connection.

Default value: 3

Connection retry interval

The time taken in seconds to wait before retrying for another connection.

Default value: 10

Multiexcerpt include macro

name	Snap Execution
page	SOAP Execute

Multiexcerpt include macro

name	Execution_Detail_Write
page	SOAP Execute

Examples

Expand

title	RabbitMQ Producer Snap with messages routing to the error view

In the below pipeline, the messages are created and sent to the RabbitMQ Producer Snap. The valid messages are sent to the output view and the invalid messages are sent to the error view. In case of a server shut down or an unplugged network, the messages are routed to the error view. Note the Script Snap is used to create a delay of 5 secs between each message.

Image Removed

The Maximum connection attempts is set to a default 3, which means the Snap attempts three times before publishing the messages. If it exceeds the configured value, the Snap fails to execute.

The output preview from the successful execution of the pipeline:

Image Removed

The Route connection errors property is selected and hence the unprocessed messages with details are sent to the error view along with the original.

Image Removed

If the Route connections errors property is disabled, the Snap fails to execute: