Problem with AMQP 0.10 reading queue using Node

28 views
Skip to first unread message

Felipe Silveira

unread,
Aug 22, 2014, 1:30:23 PM8/22/14
to nod...@googlegroups.com
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.
Reply all
Reply to author
Forward
0 new messages