How to convert AQMP message buffer into JSON object when using node.js amqp module?

node.js type-conversion node-amqp
Anand Patel picture Anand Patel · Dec 17, 2013 · Viewed 9.6k times · Source

I am using node.js amqp module for reading messages from a queue. The following is the callback that is invoked when there is a message available on the queue:

function onMessage(message, headers, deliveryInfo)
{
    console.log(message); //This prints buffer
    //how to convert message (which I expect to be JSON) into a JSON object.
    //Also how to get the JSON string from the 'message' which seems to be a buffer
}

Thanks.

Answer

Paul Mougel picture Paul Mougel · Dec 17, 2013

If you receive a Buffer that contains JSON, then you'll need to convert it to a string to output something meaningful to the console:

console.log(message.toString())

If you want to convert that string to a full JavaScript object, then just parse the JSON:

var res = JSON.parse(message.toString())

Edit: node-amqp seems to be able to send directly JavaScript objects (see here), you shouldn't be receiving buffers but instead JavaScript objects... Check how you send your messages.

Related questions

convert string to number node.js

I'm trying to convert req.params to Number because that is what I defined in my schema for year param. I have tried req.params.year = parseInt( req.params.year, 10 ); and Number( req.params.year); and 1*req.params.year; but …

Read More
How do I update Node.js?

I did the following to update my npm: npm update npm -g But I have no idea how to update Node.js. Any suggestions? (I'm using Node.js 0.4.1 and want to update to Node.js 0.6.1.)

Read More
How do I completely uninstall Node.js, and reinstall from beginning (Mac OS X)

My version of node is always v0.6.1-pre even after I install brew node and NVM install v0.6.19. My node version is: node -v v0.6.1-pre NVM says this (after I install a version of node for the first time …

Read More