Properly handle getOrCreateQueue errors & add additional logging info…

… for it
privy-gg · Apr 13, 2022 · 45dafdb · 45dafdb
1 parent 206c54e
commit 45dafdb
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/queue_manager.go b/lib/queue_manager.go
@@ -277,7 +277,9 @@ func (m *QueueManager) fulfillRequest(resp *http.ResponseWriter, req *http.Reque
 		if err != nil {
 			(*resp).WriteHeader(500)
 			(*resp).Write([]byte(err.Error()))
-			logger.Error(err)
+			ErrorCounter.Inc()
+			logger.WithFields(logrus.Fields{"function": "getOrCreateQueue", "queueType": queueType}).Error(err)
+			return
 		}
 
 		if q.identifier != "NoAuth" && m.cluster != nil {