chore(queue): missing timeout.

appleboy · appleboy · commit d151abef2f79 · 2021-08-01T14:28:47.000+08:00
Signed-off-by: Bo-Yi Wu &lt;appleboy.tw@gmail.com&gt;
diff --git a/queue.go b/queue.go
@@ -167,9 +167,13 @@ func (q *Queue) handleQueueTask(timeout time.Duration, task TaskFunc) error {
 		return ErrQueueShutdown
 	}
 
-	return q.worker.Queue(Job{
-		Task:    task,
+	data := Job{
 		Timeout: timeout,
+	}
+
+	return q.worker.Queue(Job{
+		Task: task,
+		Body: data.Encode(),
 	})
 }
 

Original file line number	Diff line number	Diff line change
`@@ -167,9 +167,13 @@ func (q *Queue) handleQueueTask(timeout time.Duration, task TaskFunc) error {`
`167`	`167`	`return ErrQueueShutdown`
`168`	`168`	`}`
`169`	`169`
`170`		`- return q.worker.Queue(Job{`
`171`		`- Task: task,`
	`170`	`+ data := Job{`
`172`	`171`	`Timeout: timeout,`
	`172`	`+ }`
	`173`	`+`
	`174`	`+ return q.worker.Queue(Job{`
	`175`	`+ Task: task,`
	`176`	`+ Body: data.Encode(),`
`173`	`177`	`})`
`174`	`178`	`}`
`175`	`179`