We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d4478da commit 45c68b5Copy full SHA for 45c68b5
examples/index.js
@@ -49,8 +49,12 @@ async function main() {
49
publisher.close()
50
51
console.log("Opening a consumer and consuming messages...")
52
- const consumer = await connection.createConsumer(testQueue, {
53
- messageHandler: (msg) => console.log(`MessageId: ${msg.message_id}; Payload: ${msg.body}`),
+ const consumer = await connection.createConsumer({
+ queue: { name: testQueue },
54
+ messageHandler: (context, msg) => {
55
+ context.accept()
56
+ console.log(`MessageId: ${msg.message_id}; Payload: ${msg.body}`)
57
+ },
58
})
59
consumer.start()
60
await sleep(5000)
0 commit comments