refactor: refactor logging to use Payload method in mockMessage struct

- Add `Payload` method to `mockMessage` struct
- Replace `m.Bytes()` with `m.Payload()` in log statements in multiple tests

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

Author: appleboy

redis_test.go

@@ -33,6 +33,10 @@ func (m mockMessage) Bytes() []byte {
 	return []byte(m.Message)
 }
 
+func (m mockMessage) Payload() []byte {
+	return []byte(m.Message)
+}
+
 func setupRedisSentinelContainer(
 	ctx context.Context,
 	t *testing.T,
@@ -339,7 +343,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) {
@@ -382,7 +386,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) {
@@ -425,15 +429,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
 				}