Nodejs: rabbitmq await consume

Question

This is my code:

// send to queue
channel.sendToQueue("test", data);

After publish test, on another server we get a response from that server

So, I want to await for it and get with await:

await channel.consume("response", async (msg) => {
  ....
})

But await not work here

How can I await for consume?

My full code:

channel.sendToQueue("test", data);
await channel.consume("response", async (msg) => {
  ....
})
// continue code

You'll probably need to wrap the `consume` call in a promise if you want to await it — Dane Brouwer, Dec 06 '22 at 09:34
Does this answer your question? [How do I convert an existing callback API to promises?](https://stackoverflow.com/questions/22519784/how-do-i-convert-an-existing-callback-api-to-promises) — Dane Brouwer, Dec 08 '22 at 08:40

Dane Brouwer · Accepted Answer · 2022-12-06T10:11:54.733

2

Construct a promise and wrap it around your consume function call. It's a callback so we can just call resolve to make our outer promise actually resolve.

channel.consume doesn't return an awaitable response so we cannot await it.

await new Promise((resolve, reject) => {
  channel.consume("response", (msg) => {
    resolve(msg);
  })
})

edited Dec 06 '22 at 10:11

answered Dec 06 '22 at 10:05

Dane Brouwer

2,827
1
22
30

Nodejs: rabbitmq await consume

1 Answers1