Hello,
I'm trying to read a Qpid queue using this package:
But I had this error error:
[Error: Frame size exceeds max frame]
Searching on the package, I found that the version it supports AMQP is 0.9.1 and I work with 0.10, does anyone know any other package or solution to make reading queues apache Qpid 0.24 and 0.10?
Code:
var amqp = require('amqp');
var connection = amqp.createConnection({ host: '127.0.0.1' });
// Wait for connection to become established.
connection.on('ready', function () {
// Use the default 'amq.topic' exchange
connection.queue('queue', function(q){
console.log(q);
// Catch all messages
q.bind('#');
// Receive messages
q.subscribe(function (message) {
// Print messages to stdout
console.log(message);
});
});
});
Thank you.