oslo.messaging.js

nodejs client for oslo.messaging

usage

var messaging = require('oslo.messaging');

var client = new messaging.RpcClient({
    url: 'amqp://localhost;amqp//10.0.0.10',
    exchange: 'exchange',
    topic: 'topic',
    version: '1.0',
    timeout: 5000,
    retryDelay: 3000,
    noAck: false
});

context = {}

client.call('name.space', context, 'method', {param: 1, param2: false}).then(function(data) {
    console.log(data);
}).catch(function(err) {
    console.log(err);
});