Basic AMQP producer/consumer implementation using `amqplib`

amqp-get-started.js

const amqp = require('amqplib');

const getChannel = async (uri = 'amqp://localhost') => {
  const connection = await amqp.connect(uri);
  return connection.createChannel();
};


const postMessages = async (channel, queue) => {
  await channel.assertQueue(queue);
  setInterval(() => channel.sendToQueue(queue, new Buffer('this is my message to the world')), 1000);
} 

const readMessages = async (channel, queue) => {
  await channel.assertQueue(queue);
  channel.consume(queue, message => console.log(message.content.toString()));
}

getChannel().then(channel => postMessages(channel, 'test')).catch(console.warn);
getChannel().then(channel => readMessages(channel, 'test')).catch(console.warn);