diff --git a/tests/jobs_test.go b/tests/jobs_test.go index 75c4fd0..213320e 100644 --- a/tests/jobs_test.go +++ b/tests/jobs_test.go @@ -363,7 +363,7 @@ func TestAutoAck(t *testing.T) { stopCh <- struct{}{} wg.Wait() - require.Equal(t, 4, oLogger.FilterMessageSnippet("auto ack is turned on, message acknowledged").Len()) + require.Equal(t, 2, oLogger.FilterMessageSnippet("auto ack is turned on, message acknowledged").Len()) } func TestRemovePQ(t *testing.T) {