Skip to main content

AMQP

The Advanced Message Queuing Protocol (AMQP) is an open standard application layer protocol for message-oriented middleware

Official Websitehttps://amqp-node.github.io/amqplib/
Documentationhttps://amqp-node.github.io/amqplib/channel_api.html
NodeJS packagehttps://www.npmjs.com/package/amqplib
Version0.10.3
Source Codehttps://github.com/amqp-node/amqplib
Tagsqueue, rabbitmq
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.

If you check the Use promise api option, you'll be able to use library using promises, otherwise the credential will use the callback api. You only can use one of both ways.

In the extra options field you can pass any of the params you can find here.

Here you have 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

Integration​

New integration from credential
const amqpConnection = await yepcode.integration.amqp('credential-slug')
New integration from plain authentication data
const amqp = require('amqplib');

amqp.connect({
  hostname: 'localhost',
  username: 'guest',
  password: 'guest',
  port: '5672',
  vhost: '/'
}).then(connection => {
  // Your code here
}).catch(console.error);
New integration from plain authentication data with callback API
const amqp = require('amqplib/callback_api');

amqp.connect({
  hostname: 'localhost',
  username: 'guest',
  password: 'guest',
  port: '5672',
  vhost: '/'
},
(error, connection) => {
  if (error) {
    console.error(error);
  }
  // Your code here
}
);

Publisher (Promise)​

Publisher (promise)
const queue = "queueName";

const publisher = (connection) => {
  return connection
    .createChannel()
    .then((channel) => {
      return channel.assertQueue(queue).then((ok) => {
        return channel.sendToQueue(
          queue,
          Buffer.from("Your message here")
        );
      });
    })
    .catch((error) => console.error(error));
};

Publisher (async/await)​

Publisher (async/await)
const queue = "queueName";

const publisher = async (connection) => {
  try {
    const channel = await connection.createChannel();
    await channel.assertQueue(queue);
    channel.sendToQueue(queue, Buffer.from("Your message here"));
  } catch (error) {
    console.error(error);
  }
};

Publisher (Callback)​

Publisher (callback)
const queue = "queueName";

const publisher = (connection) => {
  connection.createChannel((error, channel) => {
    if (error != null) console.error(error);
    channel.assertQueue(queue);
    channel.sendToQueue(queue, Buffer.from("Your message here"));
  });
};
Last updated on