From ca52ef8c8da89d0d436fe432c986d21371f36921 Mon Sep 17 00:00:00 2001 From: chuongtran Date: Sat, 1 Mar 2025 11:43:33 +0700 Subject: [PATCH] feat: Add QueueName method to ResultWriter for retrieving task queue name --- asynq.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/asynq.go b/asynq.go index dded627..f74de38 100644 --- a/asynq.go +++ b/asynq.go @@ -549,3 +549,8 @@ func (w *ResultWriter) Write(data []byte) (n int, err error) { func (w *ResultWriter) TaskID() string { return w.id } + +// QueueName returns the name of the queue the task belongs to. +func (w *ResultWriter) QueueName() string { + return w.qname +} \ No newline at end of file