RCP-Server and RCP-Client under amqplib for Node.JS

npm install amqplib-rpc-js

A library for organizing remote procedure calls based on the AMQP 0-9-1 protocol using the amqplib library.

Use on the server side

 
const Server = require('amqplib-rpc/Server');
//or
const Server = require('amqplib-rpc').Server;
 
const server = new Server({queue: "test"});
 
server.bind('method', (params, callback) => {
    //Do something
    callback(err, result);//Return result or error
});
 
//If you need verify params for correct, use schema json
server.bindSchema('method', {/*schema*/})
 
server.run()
    .then(function(res) {
        //Should return true
    })
    .catch(function(err) {
        //Return "Error" if server not started
    });
 

To stop the server, use the server.stop()

Use on the client side

 
const Client = require('amqplib-rpc/Client');
//or
const client = require('amqplib-rpc').Client;
 
const client = new Client({queue: "test"});
 
client.run()
    .then(function(res) {
        //"res" should return true
        client.call('method', params, function(err, resu) {
            //Do something with result
        });
    })
    .catch(function(err) {
        //Return "Error" if client not started
    });

To stop the client, use the client.stop()

Server options

• hostname - Address for connection to MQServer (default: 'localhost')
• port - Port for connection to MQServer (default: 5672)
• username - Username for connection to MQServer (default: 'guest')
• password - Password for connection to MQServer (default: 'guest')
• heartbeat - Heartbeat for testing connection to MQServer (default: 30 secs)
• queue - The name of the server queue. If the value is null, the name is generated automatically
• prefetch - Determines how many maximum messages the server can receive from the queue (default: 3)
• reconnect - Flag with server trying reconnection to MQ-server (default: false)
• reconnectTimeout - Each Seconds server trying reconnect to MQ-server

Client options

• hostname - Address for connection to MQServer (default: 'localhost')
• port - Port for connection to MQServer (default: 5672)
• username - Username for connection to MQServer (default: 'guest')
• password - Password for connection to MQServer (default: 'guest')
• heartbeat - Heartbeat for testing connection to MQServer (default: 30 secs)
• queue - The name of the queue to which the client requests will be sent to the server. If the value is null, the name is generated automatically
• timeout - The parameter is intended for setting the waiting for a response from the server. If the waiting time is longer than the set time, then there will be a generated TimeoutException error. The time is set in seconds. (default: 0 (infinity))

FAYULogger

Server and Client support logging with FAYULogger. You can create class FAUYLogger, create modules and transports, set into Server and/or Client:

const FAYULogger = require('fayulogger');
//Something for create Server and/or Client
 
let logger = new FAYULogger();
//Create and binding modules and transports
server.FAYULogger = logger;
client.FAYULogger = logger;

Warning

Module in develop.

Changelog

0.1.5

Add support reconnect for server and client

0.1.3

Added support json-schema for verify parameters

0.1.1

Change attribute "name" in error on "method" Change just error on class "RpcError"