Fix to increase timeout milliseconds since it's too tight rabbitmq#192

t2y · Jun 20, 2023 · a6ccf40 · a6ccf40
1 parent 13dde10
commit a6ccf40
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/integration_test.go b/integration_test.go
@@ -846,14 +846,14 @@ func TestIntegrationConsumeCancelWithContext(t *testing.T) {
 		assertConsumeBody(t, messages, []byte("1"))
 
 		cancel()
-		<-time.After(100 * time.Millisecond) // wait to call cancel asynchronously
+		<-time.After(200 * time.Millisecond) // wait to call cancel asynchronously
 
 		if e := ch.Publish("", queue, false, false, Publishing{Body: []byte("2")}); e != nil {
 			t.Fatalf("error publishing: %v", e)
 		}
 
 		select {
-		case <-time.After(100 * time.Millisecond):
+		case <-time.After(200 * time.Millisecond):
 			t.Fatalf("Timeout on Close")
 		case _, ok := <-messages:
 			if ok {