@@ -247,7 +247,7 @@ func TestJobReachTimeout(t *testing.T) {
247
247
for {
248
248
select {
249
249
case <- ctx .Done ():
250
- log .Println ("get data:" , string (m .Bytes ()))
250
+ log .Println ("get data:" , string (m .Payload ()))
251
251
if errors .Is (ctx .Err (), context .Canceled ) {
252
252
log .Println ("queue has been shutdown and cancel the job" )
253
253
} else if errors .Is (ctx .Err (), context .DeadlineExceeded ) {
@@ -290,7 +290,7 @@ func TestCancelJobAfterShutdown(t *testing.T) {
290
290
for {
291
291
select {
292
292
case <- ctx .Done ():
293
- log .Println ("get data:" , string (m .Bytes ()))
293
+ log .Println ("get data:" , string (m .Payload ()))
294
294
if errors .Is (ctx .Err (), context .Canceled ) {
295
295
log .Println ("queue has been shutdown and cancel the job" )
296
296
} else if errors .Is (ctx .Err (), context .DeadlineExceeded ) {
@@ -333,15 +333,15 @@ func TestGoroutineLeak(t *testing.T) {
333
333
for {
334
334
select {
335
335
case <- ctx .Done ():
336
- log .Println ("get data:" , string (m .Bytes ()))
336
+ log .Println ("get data:" , string (m .Payload ()))
337
337
if errors .Is (ctx .Err (), context .Canceled ) {
338
338
log .Println ("queue has been shutdown and cancel the job" )
339
339
} else if errors .Is (ctx .Err (), context .DeadlineExceeded ) {
340
340
log .Println ("job deadline exceeded" )
341
341
}
342
342
return nil
343
343
default :
344
- log .Println ("get data:" , string (m .Bytes ()))
344
+ log .Println ("get data:" , string (m .Payload ()))
345
345
time .Sleep (50 * time .Millisecond )
346
346
return nil
347
347
}
0 commit comments