chore: add error if receiver link is closed

Author: magne

src/consumer.ts

@@ -104,7 +104,7 @@ export class AmqpConsumer implements Consumer {
   start() {
     this.receiverLink.on(ReceiverEvents.message, (context: EventContext) => {
       if (context.message && context.delivery) {
-        const deliveryContext = new AmqpDeliveryContext(context.delivery)
+        const deliveryContext = new AmqpDeliveryContext(context.delivery, this.receiverLink)
         this.params.messageHandler(deliveryContext, context.message)
       }
     })

src/delivery_context.ts

@@ -1,4 +1,4 @@
-import { Delivery } from "rhea"
+import { Delivery, Receiver } from "rhea"
 
 export interface DeliveryContext {
   accept(): void
@@ -7,17 +7,26 @@ export interface DeliveryContext {
 }
 
 export class AmqpDeliveryContext implements DeliveryContext {
-  constructor(private readonly delivery: Delivery) {}
+  constructor(
+    private readonly delivery: Delivery,
+    private readonly receiverLink: Receiver
+  ) {}
 
   accept(): void {
+    if (this.receiverLink.is_closed()) throw new Error("Receiver link is closed")
+
     this.delivery.accept()
   }
 
   discard(): void {
+    if (this.receiverLink.is_closed()) throw new Error("Receiver link is closed")
+
     this.delivery.reject()
   }
 
   requeue(): void {
+    if (this.receiverLink.is_closed()) throw new Error("Receiver link is closed")
+
     this.delivery.release()
   }
 }