diff options
Diffstat (limited to 'tests/plugins/jobs/jobs_with_toxics_test.go')
| -rw-r--r-- | tests/plugins/jobs/jobs_with_toxics_test.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/tests/plugins/jobs/jobs_with_toxics_test.go b/tests/plugins/jobs/jobs_with_toxics_test.go index 85fd4fa8..7e2bd8be 100644 --- a/tests/plugins/jobs/jobs_with_toxics_test.go +++ b/tests/plugins/jobs/jobs_with_toxics_test.go @@ -132,18 +132,18 @@ func TestDurabilityAMQP(t *testing.T) { time.Sleep(time.Second * 3) go func() { - time.Sleep(time.Second * 2) - t.Run("PushPipelineWhileRedialing-1", pushToPipe("test-1")) - t.Run("PushPipelineWhileRedialing-2", pushToPipe("test-2")) + time.Sleep(time.Second * 5) + enableProxy("redial", t) }() - time.Sleep(time.Second * 5) - enableProxy("redial", t) + t.Run("PushPipelineWhileRedialing-1", pushToPipeErr("test-1")) + t.Run("PushPipelineWhileRedialing-2", pushToPipeErr("test-2")) + time.Sleep(time.Second * 15) t.Run("PushPipelineWhileRedialing-1", pushToPipe("test-1")) t.Run("PushPipelineWhileRedialing-2", pushToPipe("test-2")) - time.Sleep(time.Second * 10) + time.Sleep(time.Second * 5) stopCh <- struct{}{} wg.Wait() |