AMQP Producer

The Advanced Message Queuing Protocol (AMQP) Producer step publishes a stream of AMQP messages to an AMQP 0-9-1 compatible broker.

Before you begin

Before you use the AMQP Producer step, be aware of the following conditions:

• This step uses and requires the AMQP 0-9-1 messaging protocol.

• You must have an AMQP 0-9-1 compatible broker (such as RabbitMQ) available before you configure this step.

• Within a transformation, you can use only the AMQP Consumer step to ingest messages from any AMQP producer or broker. The AMQP Producer step is not required.

Step name

AMQP Producer dialog box

• Step name: Specify a unique name for the step on the canvas.

Use with AMQP Consumer

If you use AMQP Producer with AMQP Consumer (in the same transformation or in separate transformations), some settings must align.

In particular, make sure the producer and consumer use compatible values for:

• Exchange name (or both blank to use the default exchange)

• Exchange type

• Routing key (for DIRECT and TOPIC exchanges)

• Headers (for HEADERS exchanges)

Options

The AMQP Producer step requires you to configure the Setup and Security tabs.

Setup tab

AMQP Producer Setup tab

The Setup tab defines the broker connection and publish settings.

• Connection: The URI address of the AMQP broker that the step connects to.

  For details, see the RabbitMQ URI specification: https://www.rabbitmq.com/uri-spec.html.

• Exchange name: The exchange to publish messages to.

  • To use the default exchange, leave Exchange name blank and set Exchange type to DIRECT.

  • If you did not specify an exchange name in the AMQP Consumer step, leave Exchange name blank here too.

• Exchange type: The exchange type pattern to use.

  • DIRECT: Routes messages to queues based on the message routing key.

  • Default exchange: To use the default exchange, leave Exchange name blank and set Exchange type to DIRECT.

  • FANOUT: Routes messages to all queues bound to the exchange. The routing key is ignored.

  • TOPIC: Routes messages to one or more queues based on routing key pattern matching.

  • HEADERS: Routes messages based on one or more message header key/value pairs.

• Routing key: Required when Exchange type is DIRECT or TOPIC.

  Select a retrieval method:

  • Specify routing key: Enter a specific routing key.

  • Get data from field: Select a field to use as the routing key.

  To use the default exchange configuration:

  1. Leave Exchange name blank.

  2. Set Exchange type to DIRECT.

  3. Set Routing key to the queue name used by the consumer. (The value must match the consumer’s Queue name setting.)

• Headers: Required when Exchange type is HEADERS.

  Select a retrieval method:

  • Specify headers: Enter the header Name and Value.

  • Get data from field: Select a field to retrieve the header Name and Value.

• Message field: The input field that contains the message to publish.

Security tab

AMQP Producer Security tab

The Security tab defines authentication credentials and (optionally) SSL properties for the AMQP broker.

• Username: The user name required to access the AMQP broker.

• Password: The password associated with Username.

• Use secure protocol: Select to configure SSL properties for the connection.

• SSL properties:

  • Context Algorithm: The secure protocol name.

  • Key Store Password: The password for the keystore.

  • Key Store Path: The path to the keystore.

  • Key Store Type: The keystore type.

  • Trust Store Password: The password for the truststore.

  • Trust Store Path: The path to the truststore.

  • Trust Store Type: The truststore format.

See also

• AMQP Consumer