Version 22.0.8473

• Entering Connection Settings
• Selecting an Action
  • Produce
  • Consume

The Advanced Message Queueing Protocol (AMQP) connector allows you to integrate AMQP into your data flow by performing Produce and Consume actions on your data.

Entering Connection Settings

You must first establish a connection to AMQP through one of these two methods:

• Add a AMQP connector to your flow. Then, in the settings pane, click Create next to the Connection drop-down list.
• Open the CData Arc Settings page, then open the Connections tab. Click Add, select AMQP, and click Next.

Note:

• The login process is only required the first time the connection is created.
• Connections to AMQP can be re-used across multiple AMQP connectors.

After opening the connection dialogue, follow these steps:

1. Enter the connection information:

   • Name—the static name of the connection. Set this as desired.

   • Type—this is always set to AMQP.

   • Remote Host—the hostname or IP address of your AMQP remote host.

   • Remote Port—the port for your remote host connection.

   • Use TLS—whether to use TLS to encrypt the connection. Set this according to your AMQP configuration.

   • Container Id—(optional) the ID value for the container in your AMQP connection that you want to access.

   • Auth Scheme—the authentication scheme to use for the connection. Options are None, SASL Anonymous, and SASL Plain.

   If you select SASL Anonymous or SASL Plain authentication, enter the following information:

   • User—the username to use when connecting to AMQP.

   • Password—the password for the user.

2. Click Test Connection to ensure that Arc can connect to AMQP with the provided information. If an error occurs, check all fields and try again.

3. Click Add Connection to finalize the connection.

4. Select your newly-created connection in the Connection drop-down list of the connector configuration pane.

Selecting an Action

After establishing a connection to AMQP, you must choose the action that the AMQP connector will perform. The table below outlines each action and where it belongs in an CData Arc flow:

Action	Description	Position in Flow
Produce	Accepts input data from a file or another connector and sends it to your AMQP connection.	End
Consume	Listens for messages coming into the queue and sends incoming data down the flow through the Output path.	Beginning

Produce

The Produce action sends input data to your AMQP connection. This data can come from other connectors or from files that you manually upload to the Input tab of the AMQP connector.

In some AMQP configurations, you can set the value of the Target field to the address of the node that should act as the receiver. This may not be necessary in all configurations, and you can leave this field blank if needed.

Consume

The Consume action checks for messages in the AMQP queue. Data processed through the Consume connector goes to the Output tab and travels down to the next steps of the Arc flow.

In some AMQP configurations, you can set the value of the Target field to the address of the node that the connector should receive data from. This may not be necessary in all configurations, and you can leave this field blank if needed.