chore: fix timeout bugs (#24)

appleboy · web-flow · commit 6d3b0b93613b · 2021-07-29T21:15:11.000+08:00
Signed-off-by: Bo-Yi Wu &lt;appleboy.tw@gmail.com&gt;
diff --git a/queue.go b/queue.go
@@ -28,8 +28,8 @@ type (
 
 	// Job with Timeout
 	Job struct {
-		Timeout time.Duration
-		Body    []byte
+		Timeout time.Duration `json:"timeout"`
+		Body    []byte        `json:"body"`
 	}
 )
 
@@ -154,7 +154,7 @@ func (q *Queue) Queue(job QueuedMessage) error {
 
 // Queue to queue all job
 func (q *Queue) QueueWithTimeout(timeout time.Duration, job QueuedMessage) error {
-	return q.handleQueue(q.timeout, job)
+	return q.handleQueue(timeout, job)
 }
 
 func (q *Queue) work() {

Original file line number	Diff line number	Diff line change
`@@ -28,8 +28,8 @@ type (`
`28`	`28`
`29`	`29`	`// Job with Timeout`
`30`	`30`	`Job struct {`
`31`		`- Timeout time.Duration`
`32`		`- Body []byte`
	`31`	+ Timeout time.Duration `json:"timeout"`
	`32`	+ Body []byte `json:"body"`
`33`	`33`	`}`
`34`	`34`	`)`
`35`	`35`
`@@ -154,7 +154,7 @@ func (q *Queue) Queue(job QueuedMessage) error {`
`154`	`154`
`155`	`155`	`// Queue to queue all job`
`156`	`156`	`func (q *Queue) QueueWithTimeout(timeout time.Duration, job QueuedMessage) error {`
`157`		`- return q.handleQueue(q.timeout, job)`
	`157`	`+ return q.handleQueue(timeout, job)`
`158`	`158`	`}`
`159`	`159`
`160`	`160`	`func (q *Queue) work() {`