error: Queue.onMessage consumer function returned error: content is not a buffer module=amqp-ts

[abreits]

error: Queue.onMessage consumer function returned error: content is not a buffer module=amqp-ts

[razzeee]

Did you figure this out?

[austin-beer]

I encountered this error when receiving a message that had the replyTo (reply-to) field set. In that case, the message is treated as an RPC call. The amqp-ts library automatically sends the queue.activateConsumer onMessage function's return value to the sender (i.e. to wherever the replyTo field is set to). If your onMessage function doesn't return anything, you will get this error: "Queue.onMessage consumer function returned error: content is not a buffer module=amqp-ts".

https://github.com/abreits/amqp-ts/wiki/Queue-class#activateConsumer

[bruegth]

Seems documentation/example is wrong:

// rpc server that returns a Message
queue.activateConsumer((msg) => {
    var rpcParameters = msg.getContent();
    return new Amqp.Message(rpcParameters.value, {});
});

because return value for reply queue will be stringified:

amqp-ts/src/amqp-ts.ts

Line 798 in 0ca8250

content = new Buffer(JSON.stringify(content));

Or?