Heartbeat bug fixed

carlhoerberg · carlhoerberg · commit aa6922489bf0 · 2022-03-07T19:49:34.000+01:00
Fixes #31
diff --git a/src/amqp-base-client.ts b/src/amqp-base-client.ts
@@ -570,7 +570,7 @@ export abstract class AMQPBaseClient {
           break
         }
         case 8: { // heartbeat
-          const heartbeat = new Uint8Array([1, 0, 0, 0, 0, 0, 0, 206])
+          const heartbeat = new Uint8Array([8, 0, 0, 0, 0, 0, 0, 206])
           this.send(heartbeat).catch(err => console.warn("Error while sending heartbeat", err))
           break
         }
diff --git a/test/test.ts b/test/test.ts
@@ -584,3 +584,11 @@ test("can handle cancel from server", async t => {
   await q.delete()
   await t.throwsAsync(() => consumer.wait(), { message: /Consumer cancelled by the server/ })
 })
+
+test("can handle heartbeats", async t => {
+  const amqp = new AMQPClient("amqp://127.0.0.1?heartbeat=1")
+  const conn = await amqp.connect()
+  const wait = new Promise((resolv) => setTimeout(resolv, 2000))
+  await wait
+  t.is(conn.closed, false)
+})

Original file line number	Diff line number	Diff line change
`@@ -570,7 +570,7 @@ export abstract class AMQPBaseClient {`
`570`	`570`	`break`
`571`	`571`	`}`
`572`	`572`	`case 8: { // heartbeat`
`573`		`- const heartbeat = new Uint8Array([1, 0, 0, 0, 0, 0, 0, 206])`
	`573`	`+ const heartbeat = new Uint8Array([8, 0, 0, 0, 0, 0, 0, 206])`
`574`	`574`	`this.send(heartbeat).catch(err => console.warn("Error while sending heartbeat", err))`
`575`	`575`	`break`
`576`	`576`	`}`