chore: rename body to payload

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

Author: appleboy

go.mod

@@ -3,7 +3,7 @@ module github.com/golang-queue/nsq
 go 1.16
 
 require (
-	github.com/golang-queue/queue v0.0.11
+	github.com/golang-queue/queue v0.0.12-0.20220122071422-2c41650f045a
 	github.com/nsqio/go-nsq v1.1.0
 	github.com/stretchr/testify v1.7.0
 	go.uber.org/goleak v1.1.12

go.sum

@@ -2,6 +2,8 @@ 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-queue/queue v0.0.11 h1:qaE7rOYUh+11NcO6U9zZ7NazglIwEp0j7Dn0sSoavcI=
 github.com/golang-queue/queue v0.0.11/go.mod h1:ku8iyjYffqYY6Duts+xl+QYfN3/KDK4MEvXMZUkHyio=
+github.com/golang-queue/queue v0.0.12-0.20220122071422-2c41650f045a h1:olgbdu53u5A6Babr1w+CUO19UdZASYPPqqIBfdFWrWE=
+github.com/golang-queue/queue v0.0.12-0.20220122071422-2c41650f045a/go.mod h1:ku8iyjYffqYY6Duts+xl+QYfN3/KDK4MEvXMZUkHyio=
 github.com/golang/snappy v0.0.1 h1:Qgr9rKW7uDUkrbSmQeiDsGa8SjGyCOGtuasMWwvp2P4=
 github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 github.com/kr/pretty v0.1.0 h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI=

nsq_test.go

@@ -295,7 +295,7 @@ func TestGoroutinePanic(t *testing.T) {
 func TestHandleTimeout(t *testing.T) {
 	job := queue.Job{
 		Timeout: 100 * time.Millisecond,
-		Body:    []byte("foo"),
+		Payload: []byte("foo"),
 	}
 	w := NewWorker(
 		WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
@@ -311,7 +311,7 @@ func TestHandleTimeout(t *testing.T) {
 
 	job = queue.Job{
 		Timeout: 150 * time.Millisecond,
-		Body:    []byte("foo"),
+		Payload: []byte("foo"),
 	}
 
 	w = NewWorker(
@@ -337,7 +337,7 @@ func TestHandleTimeout(t *testing.T) {
 func TestJobComplete(t *testing.T) {
 	job := queue.Job{
 		Timeout: 100 * time.Millisecond,
-		Body:    []byte("foo"),
+		Payload: []byte("foo"),
 	}
 	w := NewWorker(
 		WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
@@ -352,7 +352,7 @@ func TestJobComplete(t *testing.T) {
 
 	job = queue.Job{
 		Timeout: 250 * time.Millisecond,
-		Body:    []byte("foo"),
+		Payload: []byte("foo"),
 	}
 
 	w = NewWorker(
@@ -378,7 +378,7 @@ func TestJobComplete(t *testing.T) {
 func TestBusyWorkerCount(t *testing.T) {
 	job := queue.Job{
 		Timeout: 500 * time.Millisecond,
-		Body:    []byte("foo"),
+		Payload: []byte("foo"),
 	}
 
 	w := NewWorker(