chore(example): update nsq exmaple

Signed-off-by: Bo-Yi Wu <[email protected]>

Author: appleboy

_example/nsq/go.mod

@@ -2,4 +2,4 @@ module example
 
 go 1.16
 
-require github.com/appleboy/queue v0.0.4-0.20210726090849-82cf3ebeafc5
+require github.com/appleboy/queue v0.0.4-0.20210730034730-99a80f7c71f6

_example/nsq/go.sum

@@ -6,6 +6,8 @@ github.com/appleboy/queue v0.0.4-0.20210726005953-79774a856a1e h1:+Mj8GY3F5J6rJC
 github.com/appleboy/queue v0.0.4-0.20210726005953-79774a856a1e/go.mod h1:6Mn0z4hURZW/26huvRXG0SJ4o7pBdo6hOryRiegy/4Q=
 github.com/appleboy/queue v0.0.4-0.20210726090849-82cf3ebeafc5 h1:UE6zMJQObLz/E/RcV3EMEXnU2wmeftvf9kNHozS5300=
 github.com/appleboy/queue v0.0.4-0.20210726090849-82cf3ebeafc5/go.mod h1:cEQW2y7dduAUqUGnGJEK9oM5bZLlc0+3HI9bTUL0+Ek=
+github.com/appleboy/queue v0.0.4-0.20210730034730-99a80f7c71f6 h1:IKX9oSPYXWXIvJ3aDqEM458S5gRsFUs9zzFND645te0=
+github.com/appleboy/queue v0.0.4-0.20210730034730-99a80f7c71f6/go.mod h1:cEQW2y7dduAUqUGnGJEK9oM5bZLlc0+3HI9bTUL0+Ek=
 github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=

_example/nsq/main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"log"
@@ -33,7 +34,7 @@ func main() {
 		nsq.WithChannel("foobar"),
 		// concurrent job number
 		nsq.WithMaxInFlight(10),
-		nsq.WithRunFunc(func(m queue.QueuedMessage, _ <-chan struct{}) error {
+		nsq.WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
 			v, ok := m.(*job)
 			if !ok {
 				if err := json.Unmarshal(m.Bytes(), &v); err != nil {