1.0.9 • Published 5 years ago

rabbitmq-boilerplate v1.0.9

Weekly downloads
3
License
ISC
Repository
github
Last release
5 years ago
const Rabbitmq = require("./index.js"),  
    async = require("async");

const rabbitmq = new Rabbitmq();

//can be hot-swapped
rabbitmq.config("amqp://localhost");
 
rabbitmq.send({"value": Math.random()}, "queuename", (err) => {
    if (err){
        return console.error(err)
    }
    console.log("sended")
});

rabbitmq.listen("queuename", (err, msg) => {
    if (err) {
        return console.error("you should call rabbitmq.listen again", err.toString())
    }
    console.log("received", msg.payload);
    msg.release(); //or msg.reject();
});
1.0.11-beta

5 years ago

1.0.10-beta

5 years ago

1.0.9

6 years ago

1.0.8

6 years ago

1.0.7

6 years ago

1.0.6

7 years ago

1.0.5

7 years ago

1.0.4

7 years ago

1.0.3

7 years ago

1.0.2

7 years ago

1.0.1

7 years ago

1.0.0

7 years ago