1.0.0 • Published 8 years ago
node-amqp-lib v1.0.0
Node AMQP lib
Install
npm i --save node-amqp-lib
Quick start
const config = {
host: 'localhost',
port: 5672,
username: 'guest',
password: 'guest'
};
const nodeAMQPLib = new NodeAMQPLib(config)
nodeAMQPLib.subscribe('testQueue', 'test.key', (message, headers, deliveryInfo, messageObject) => {
assert.deepEqual({foo: 'bar'}, message);
messageObject.acknowledge(true);
nodeAMQPLib.destroyQueue('testQueue');
done();
})
.then(() => nodeAMQPLib.publish('test.key', {foo: 'bar'}))
.then(result => assert(result))
.catch(err => assert.ifError(err));