chore(example): update NATS exmaple

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

Author: appleboy

_example/nats/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/nats/go.sum

@@ -1,5 +1,7 @@
 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/nats/main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"log"
@@ -31,7 +32,7 @@ func main() {
 		nats.WithAddr("127.0.0.1:4222"),
 		nats.WithSubj("example"),
 		nats.WithQueue("foobar"),
-		nats.WithRunFunc(func(m queue.QueuedMessage, _ <-chan struct{}) error {
+		nats.WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
 			v, ok := m.(*job)
 			if !ok {
 				if err := json.Unmarshal(m.Bytes(), &v); err != nil {