fix(message): Finish sends a FIN command to the nsqd

Signed-off-by: Bo-Yi Wu <[email protected]>
golang-queue · Apr 18, 2022 · d79fb34 · d79fb34
1 parent 945096e
commit d79fb34
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)
 	}))