Skip to main content

AMQP Listener

Listen for messages published on Advanced Message Queuing Protocol (AMQP) queues.

Tagsqueuerabbitmq
Network Connection needs

This integration needs network access to the server where the service is running.

See the Network access page for details about how to achieve that.

Credential configuration​

To configure this credential, you need to fill the credential configuration form with the RabbitMQ connection parameters: host, port, username, password and vhost.

In the extra options field, you can include any of the parameters you found here.

Additionally to the connection information, you'll need to fill the following fields:

  • queue: name of the queue you want to listen. Listener will perform an assertQueue
  • bindings configuration (optional): to be provided to the bindQueue method
  • acknowledge approach you want to use:
    • CALLBACK_FINISHES: ack is called after callback finishes
    • CALLBACK_FINISHES_OK: ack is called after callback finishes with success. If fail, nack is done
    • IMMEDIATELY: ack is called just after receive the message

Here is an example of a filled credential configuration form in YepCode:

AMQP Snippets available in editor​

note

The title is the triggering text for YepCode to autocomplete the script.

Listener​

New listener
const listener = await yepcode.listener.amqp("playground-yepcode-amqp-listener");

listener.start((message) => {
  console.log(`New message received`, message.content.toString());
});