go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-19 23:30:20 +08:00
Code Issues Projects Releases Wiki Activity

feat: Add QueueName method to ResultWriter for retrieving task queue name

Browse Source
This commit is contained in:
chuongtran 2025-03-01 11:43:33 +07:00
parent 489e21920b
commit ca52ef8c8d
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
asynq.go
View File

@ -549,3 +549,8 @@ func (w *ResultWriter) Write(data []byte) (n int, err error) {
func (w *ResultWriter) TaskID() string { func (w *ResultWriter) TaskID() string {
return w.id return w.id
} }
// QueueName returns the name of the queue the task belongs to.
func (w *ResultWriter) QueueName() string {
return w.qname
}