refactor: refactor JSON unmarshalling to use Payload instead of Bytes

- Change `m.Bytes()` to `m.Payload()` in the main function for unmarshalling JSON
- Update test cases to use `m.Payload()` instead of `m.Bytes()` for logging data

Signed-off-by: appleboy <[email protected]>

Author: appleboy

README.md

@@ -75,7 +75,7 @@ func main() {
     nsq.WithMaxInFlight(10),
     nsq.WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
       var v *job
-      if err := json.Unmarshal(m.Bytes(), &v); err != nil {
+      if err := json.Unmarshal(m.Payload(), &v); err != nil {
         return err
       }
       rets <- v.Message

nsq_test.go

@@ -139,7 +139,7 @@ func TestJobReachTimeout(t *testing.T) {
 			for {
 				select {
 				case <-ctx.Done():
-					log.Println("get data:", string(m.Bytes()))
+					log.Println("get data:", string(m.Payload()))
 					if errors.Is(ctx.Err(), context.Canceled) {
 						log.Println("queue has been shutdown and cancel the job")
 					} else if errors.Is(ctx.Err(), context.DeadlineExceeded) {
@@ -178,7 +178,7 @@ func TestCancelJobAfterShutdown(t *testing.T) {
 			for {
 				select {
 				case <-ctx.Done():
-					log.Println("get data:", string(m.Bytes()))
+					log.Println("get data:", string(m.Payload()))
 					if errors.Is(ctx.Err(), context.Canceled) {
 						log.Println("queue has been shutdown and cancel the job")
 					} else if errors.Is(ctx.Err(), context.DeadlineExceeded) {
@@ -217,15 +217,15 @@ func TestGoroutineLeak(t *testing.T) {
 			for {
 				select {
 				case <-ctx.Done():
-					log.Println("get data:", string(m.Bytes()))
+					log.Println("get data:", string(m.Payload()))
 					if errors.Is(ctx.Err(), context.Canceled) {
 						log.Println("queue has been shutdown and cancel the job")
 					} else if errors.Is(ctx.Err(), context.DeadlineExceeded) {
 						log.Println("job deadline exceeded")
 					}
 					return nil
 				default:
-					log.Println("get data:", string(m.Bytes()))
+					log.Println("get data:", string(m.Payload()))
 					time.Sleep(50 * time.Millisecond)
 					return nil
 				}