avoid starvation by configuring max. number of retries of an event (b…

…ackoff is exponential in nsq by default) and increase concurrency by processing at most two events at a time

internal/bmc/nsq.go

@@ -45,14 +45,15 @@ func (b *BMCService) InitConsumer() error {
 		MinVersion:   tls.VersionTLS12,
 	}
 	config.TlsV1 = true
+	config.MaxAttempts = 3
+	config.MaxInFlight = 2
 
 	consumer, err := nsq.NewConsumer(b.machineTopic, mqChannel, config)
 	if err != nil {
 		return err
 	}
 
 	consumer.SetLogger(nsqLogger{log: b.log}, nsqMapLevel(b.log))
-
 	consumer.AddHandler(b)
 
 	err = consumer.ConnectToNSQD(b.mqAddress)