rabbitmq-tt

Cài module:

$ npm install --save rabbitmq-tt

Sử dụng module

import {Rpc, Publisher, WorkerManager, ExchangeManager} from 'rabbitmq-tt';
 

Rpc

import {Rpc} from 'rabbitmq-tt';
var rpc = Rpc('amqp://username:password@host/vhost', {timeout: 10000});
 
// Rpc client
var client = rpc.client();
 
setInterval(function() {
    let request = client.request('hello', {test: 1});
 
    request.then(data => {
        console.log(data);
    }).catch(e =>{
        console.log(e);
    });
}, 1000);
 
// Rpc server
var server = rpc.server();
 
server.on('hello', function(data, callback) {
    console.log('server todo', data);
    callback(null, {a: 'Hi'});
});

Publish to worker

import {Publisher} from 'rabbitmq-tt';
 
var publisher = Publisher('amqp://username:password@host/vhost');
 
var nb = 0;
setInterval(function() {
    publisher.publish('', 'queuename', {number: nb++});
}, 100);
 

Worker

import {WorkerManager} from 'rabbitmq-tt';
var workerManager = WorkerManager('amqp://username:password@host/vhost');
 
const handle = (params, callback) => {
    console.log(params);
    setTimeout(function() {
        callback();
    }, 0);
};
 
workerManager.addWorker('queuename', handle);