Merge branch 'v3' of github.com:vmihailenco/taskq into v3

vmihailenco · vmihailenco · commit 17eecbcdc4ba · 2021-03-01T18:27:53.000+02:00
diff --git a/consumer.go b/consumer.go
@@ -636,7 +636,7 @@ func (c *Consumer) delete(msg *Message) {
 
 	err := c.q.Delete(msg)
 	if err != nil {
-		internal.Logger.Printf("taks=%q Delete failed: %s", msg.TaskName, err)
+		internal.Logger.Printf("task=%q Delete failed: %s", msg.TaskName, err)
 	}
 	atomic.AddUint32(&c.inFlight, ^uint32(0))
 }

Original file line number	Diff line number	Diff line change
`@@ -636,7 +636,7 @@ func (c Consumer) delete(msg Message) {`
`636`	`636`
`637`	`637`	`err := c.q.Delete(msg)`
`638`	`638`	`if err != nil {`
`639`		`- internal.Logger.Printf("taks=%q Delete failed: %s", msg.TaskName, err)`
	`639`	`+ internal.Logger.Printf("task=%q Delete failed: %s", msg.TaskName, err)`
`640`	`640`	`}`
`641`	`641`	`atomic.AddUint32(&c.inFlight, ^uint32(0))`
`642`	`642`	`}`