var dnode = require('dnode');
var Server = require('pm2-2.x-rpc').Server;
 
var server = new Server();
var client = dnode();
 
// pipe the stream through any transport
client.pipe(server).pipe(client);
 
client.on('remote', function (pm2) {
    // got the pm2 instance
    // use whatever pm2 api method
    pm2.connect(function (err) {
        assert.ok(!err);
    })
})

var server = new Server();
var client = dnode();
var tcpServer = server.listen(5000);
 
tcpServer.on('listening', function () {
    client.connect(5000);
    client.on('remote', function (remote) {
        client.end();
        tcpServer.close()
    })
})

var local = new Server();
var distServer = dnode().listen(5000);
 
distServer.on('listening', function () {
    local.connect(5000);
    distServer.on('remote', function (remote) {
        local.end();
        distServer.close();
    })
})