Respect concurrency in GCP (#762)

RichardKnop · Oct 12, 2023 · 3dfcfdd · 3dfcfdd
1 parent 341aa3a
commit 3dfcfdd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/v1/brokers/gcppubsub/gcp_pubsub.go b/v1/brokers/gcppubsub/gcp_pubsub.go
@@ -92,6 +92,7 @@ func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcess
 	}
 
 	sub.ReceiveSettings.NumGoroutines = concurrency
+	sub.ReceiveSettings.MaxOutstandingMessages = concurrency
 	log.INFO.Print("[*] Waiting for messages. To exit press CTRL+C")
 
 	ctx, cancel := context.WithCancel(context.Background())