test: update testing queue number

appleboy · appleboy · commit a23586542010 · 2022-04-23T15:50:33.000+08:00
diff --git a/nats_test.go b/nats_test.go
@@ -367,11 +367,9 @@ func TestReQueueTaskInWorkerBeforeShutdown(t *testing.T) {
 		WithQueue("test02"),
 	)
 
-	assert.NoError(t, w.Queue(job))
-	assert.NoError(t, w.Queue(job))
 	assert.NoError(t, w.Queue(job))
 	time.Sleep(500 * time.Millisecond)
-	// see "re-queue the old job" message
+	// see "re-queue the current task" message
 	assert.NoError(t, w.Shutdown())
 }
 

Original file line number	Diff line number	Diff line change
`@@ -367,11 +367,9 @@ func TestReQueueTaskInWorkerBeforeShutdown(t *testing.T) {`
`367`	`367`	`WithQueue("test02"),`
`368`	`368`	`)`
`369`	`369`
`370`		`- assert.NoError(t, w.Queue(job))`
`371`		`- assert.NoError(t, w.Queue(job))`
`372`	`370`	`assert.NoError(t, w.Queue(job))`
`373`	`371`	`time.Sleep(500 * time.Millisecond)`
`374`		`- // see "re-queue the old job" message`
	`372`	`+ // see "re-queue the current task" message`
`375`	`373`	`assert.NoError(t, w.Shutdown())`
`376`	`374`	`}`
`377`	`375`