feat: 创建队列错误

xiaojiaoyu100 · Jun 11, 2020 · 958a181 · 958a181
1 parent d7634eb
commit 958a181
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/consumer.go b/consumer.go
@@ -180,10 +180,10 @@ func (c *Consumer) CreateQueueList(fetchQueueReady chan struct{}) chan struct{}
 					_, err := c.CreateQueue(queue.Name, queue.AttributeSetters...)
 					return err
 				})
-				switch err {
-				case nil:
-				case createQueueConflictError, unknownError:
-					c.logger.Warn("CreateQueue", zap.Error(err))
+				if err != nil && !lockguard.IsLockNotObtained(err) {
+					c.logger.Warn("CreateQueue",
+						zap.Error(err),
+						zap.String("queue", queue.Name))
 				}
 			}
 			createQueueReady <- struct{}{}