chore(simple): update simple queue example (#21)

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

Author: appleboy

README.md

@@ -36,7 +36,11 @@ type job struct {
 }
 
 func (j *job) Bytes() []byte {
-  return []byte(j.Message)
+  b, err := json.Marshal(j)
+  if err != nil {
+    panic(err)
+  }
+  return b
 }
 ```
 
@@ -46,7 +50,7 @@ The second step to create the new worker, use the buffered channel as an example
 // define the worker
 w := simple.NewWorker(
   simple.WithQueueNum(taskN),
-  simple.WithRunFunc(func(m queue.QueuedMessage, stop <-chan struct{}) error {
+  simple.WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
     v, ok := m.(*job)
     if !ok {
       if err := json.Unmarshal(m.Bytes(), &v); err != nil {
@@ -70,7 +74,7 @@ w := nsq.NewWorker(
   nsq.WithChannel("foobar"),
   // concurrent job number
   nsq.WithMaxInFlight(10),
-  nsq.WithRunFunc(func(m queue.QueuedMessage, stop <-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 {
@@ -91,7 +95,7 @@ w := nats.NewWorker(
   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 {

_example/simple/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.20210727142412-eaaf46bd6231

_example/simple/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.20210727142412-eaaf46bd6231 h1:OGNVcnnlPLRiK27xIcinWDCITRNJYHdO5SBLfl2DuFA=
+github.com/appleboy/queue v0.0.4-0.20210727142412-eaaf46bd6231/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/simple/main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"log"
@@ -15,7 +16,11 @@ type job struct {
 }
 
 func (j *job) Bytes() []byte {
-	return []byte(j.Message)
+	b, err := json.Marshal(j)
+	if err != nil {
+		panic(err)
+	}
+	return b
 }
 
 func main() {
@@ -25,7 +30,7 @@ func main() {
 	// define the worker
 	w := simple.NewWorker(
 		simple.WithQueueNum(taskN),
-		simple.WithRunFunc(func(m queue.QueuedMessage, _ <-chan struct{}) error {
+		simple.WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
 			v, ok := m.(*job)
 			if !ok {
 				if err := json.Unmarshal(m.Bytes(), &v); err != nil {