[stream] 优化大仓触发耗时 TencentBlueKing#10861

yongyiduan · Aug 23, 2024 · e9e073a · e9e073a
1 parent 40c2de6
commit e9e073a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...z-stream/src/main/kotlin/com/tencent/devops/stream/trigger/service/UserMessageConsumer.kt b/...z-stream/src/main/kotlin/com/tencent/devops/stream/trigger/service/UserMessageConsumer.kt
@@ -44,7 +44,7 @@ class UserMessageConsumer @Autowired constructor(
         private val consumer: UserMessageConsumer
     ) : Runnable {
 
-        private val lock = "user_message_process_${consumer.bkTag}"
+        private val lock = "user_message_process_${consumer.bkTag.getLocalTag()}"
         private val key = consumer.bufferKey()
 
         companion object {