From d79fb34fedad4dfe30a8cae05833f5f6191aadb7 Mon Sep 17 00:00:00 2001
From: Bo-Yi Wu <appleboy.tw@gmail.com>
Date: Mon, 18 Apr 2022 13:09:20 +0800
Subject: [PATCH] fix(message): Finish sends a FIN command to the nsqd

Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com>
---
 nsq.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/nsq.go b/nsq.go
index 6f2a8d9..d699042 100644
--- a/nsq.go
+++ b/nsq.go
@@ -166,6 +166,7 @@ func (w *Worker) Run() error {
 
 		var data queue.Job
 		_ = json.Unmarshal(msg.Body, &data)
+		msg.Finish()
 		return w.handle(data)
 	}))