1.1.1 • Published 8 years ago
common-transport v1.1.1
CommonTransport
Common interface for communication between services.
Righ now it only supports AMQP protocol.
Example:
//server:
import {CommonTransport} from 'common-transport';
let transport = new CommonTransport({
adapter: 'amqp',
amqp: {
host: 'localhost',
port: 5672,
user: 'guest',
pass: 'guest'
}
});
transport.on('products.get' function (params, reply) {
reply([
{
id: 'product-1',
//....
}
]);
});
//client:
import {CommonTransport} from 'common-transport';
let transport = new CommonTransport({
adapter: 'amqp',
amqp: {
host: 'localhost',
port: 5672,
user: 'guest',
pass: 'guest'
}
});
(async function () {
try {
let products = await transport.call('products.get');
} catch (err) {
//an error occured
}
}());