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