ttamqp

Cài module:

$ npm install --save @lib/ttamqp

Sử dụng module

import {Publisher, WorkerManager} from '@lib/ttamqp';
 

Queue

import {Rpc, Publisher} from '@lib/ttamqp';
 
/////////////////////// Nhận job và xử lý
var workerManager = new WorkerManager({url: 'amqp://username:password@10.3.31.222/vhost'});
 
const handle = (params, callback) => {
    // params là data được gửi đến
 
    // todo ...
 
    // sau khi xử lý xong thì callback lại.
    // thành công: callback(null)
    // có lỗi: callback(error). Khi có lỗi thì job sẽ được push ngược vào queue để xử lý lại
    callback(null);
};
 
// jobhandler chính là tên queue
workerManager.addWorker('jobhandler', handle);
 
////////////////////// push job tới queue
var publisher = new Publisher({url: 'amqp://username:password@10.3.31.222/vhost'});
 
publisher.publish('', 'jobhandler', {number: 1});