increase max in flight

metal-stack · Jul 9, 2024 · 1acc726 · 1acc726
1 parent e7bf557
commit 1acc726
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/bmc/nsq.go b/internal/bmc/nsq.go
@@ -45,7 +45,7 @@ func (b *BMCService) InitConsumer() error {
 		MinVersion:   tls.VersionTLS12,
 	}
 	config.TlsV1 = true
-	config.MaxInFlight = 2
+	config.MaxInFlight = 100
 
 	consumer, err := nsq.NewConsumer(b.machineTopic, mqChannel, config)
 	if err != nil {