sbqueue

A library that queues data in memory and pushes it to an amqp connection. Built on rhea library

Getting Started

const sbqueue = require("sbqueue");

const connectionOptions = {
  host: "localhost",
  port: 5672
}

myQueue = new sbqueue(connectionOptions,"queueName");
myQueue.connect();

// Now we can push items to myQueue whenever we like
// they will be pushed to our amqp link whenever sending credit is available

myQueue.push({body: "a message"});
myQueue.push({body: "a second message"});