AMQP 1.0

AMQP is an open source messaging protocol that operates at the application layer of the ISO OSI model. It defines the interaction between the message provider and client, similar to protocols like HTTP, FTP, SMTP and others.

Note:

  • The AMQP 1.0 connector supports the AMQP 1.0 messaging protocol. Currently, the AMQP 1.0 messaging protocol configuration is limited exclusively to queues.

  • In earlier versions, only queue-based messaging was supported, where each message was consumed by a single consumer. Starting with version 3 (v3), support for topic-based (publish-subscribe) messaging has been added, enabling multiple subscribers to receive the same message. This enhancement is fully backward compatible, and existing queue-based implementations continue to work without any changes.

  • You can establish a connection from your private VPC using a private link for this connector.

Triggers

  • Subscribe: Triggers when a subscriber receives a message from the publisher

Actions

  • Publish Message: Publish a new message to a queue

Messaging patterns

Queue (Point-to-Point)

  • Messages are stored until consumed.

  • Consumers can receive messages even if they are inactive when sent.

  • Suitable for task processing and job queues.

Topic (Publish-Subscribe)

  • Messages are delivered only to active subscribers.

  • Multiple subscribers can receive the same message.

  • Messages are not retained unless durability is configured.

Wildcard topic subscriptions

Wildcard topic subscriptions allow you to receive messages from multiple topics using a single subscription pattern. The supported wildcard syntax and topic separator format depend on the messaging broker you use.

For example:
  • Solace uses / as the topic separator and supports:
    • * to match exactly one level
    • > to match one or more levels

    Example: /orders/*/v1

  • ActiveMQ Artemis and Amazon MQ use . as the topic separator and support:
    • * to match exactly one level
    • # to match zero or more levels

    Example: orders.*.v1

Examples:
  • For Solace-style topics:
    • /orders/*

      Matches /orders/created and /orders/updated.

      Does not match /orders/created/v1.

    • /orders/>

      Matches all topics under /orders, such as /orders/created/v1.

  • For Artemis/Amazon MQ-style topics:
    • orders.*

      Matches orders.created and orders.updated.

      Does not match orders.created.v1.

    • orders.#

      Matches orders.created, orders.created.v1, and orders.updated.eu.v2.

Supported brokers

The AMQP 1.0 connector is compatible with messaging brokers that support the AMQP 1.0 protocol and has been tested with:
  • Amazon MQ
  • Solace
  • ActiveMQ Artemis