From e9e073a07897001f496ae37840ace6205a62327b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?yongyiduan=28=E6=AE=B5=E6=B0=B8=E5=84=84=29?=
 <yongyiduan@tencent.com>
Date: Fri, 23 Aug 2024 14:42:00 +0800
Subject: [PATCH] =?UTF-8?q?[stream]=20=E4=BC=98=E5=8C=96=E5=A4=A7=E4=BB=93?=
 =?UTF-8?q?=E8=A7=A6=E5=8F=91=E8=80=97=E6=97=B6=20#10861?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../devops/stream/trigger/service/UserMessageConsumer.kt        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/backend/ci/core/stream/biz-stream/src/main/kotlin/com/tencent/devops/stream/trigger/service/UserMessageConsumer.kt b/src/backend/ci/core/stream/biz-stream/src/main/kotlin/com/tencent/devops/stream/trigger/service/UserMessageConsumer.kt
index 74d8017ca80..83d1e2a5d3d 100644
--- a/src/backend/ci/core/stream/biz-stream/src/main/kotlin/com/tencent/devops/stream/trigger/service/UserMessageConsumer.kt
+++ b/src/backend/ci/core/stream/biz-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 {