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:[email protected]/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:[email protected]/vhost'});

publisher.publish('', 'jobhandler', {number: 1});