Stream queue example

carlhoerberg · carlhoerberg · commit 548bcd39119a · 2022-04-26T14:03:41.000+02:00
diff --git a/examples/stream.js b/examples/stream.js
@@ -0,0 +1,15 @@
+import { AMQPClient } from '../lib/mjs/amqp-client.js'
+
+async function run() {
+  const amqp = new AMQPClient("amqp://localhost")
+  const conn = await amqp.connect()
+  let ch = await conn.channel()
+  await ch.prefetch(100)
+  let q = await ch.queue("stream1", {}, {"x-queue-type": "stream" })
+  const consumer = await q.subscribe({noAck: false, args: {"x-stream-offset": "first"}}, (msg) => {
+    console.log(msg.bodyString())
+    msg.ack()
+  })
+  await consumer.wait()
+}
+await run()
