From 39cb37420a5093e014f30beaacb6a1d5bf63c8b6 Mon Sep 17 00:00:00 2001
From: Nick Zeng <Nick.Zeng@wpic.co>
Date: Wed, 4 Feb 2026 15:28:55 +0800
Subject: [PATCH] update

---
 backend/config/autoload/mq_user.php | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/backend/config/autoload/mq_user.php b/backend/config/autoload/mq_user.php
index dfadeef..75ca456 100644
--- a/backend/config/autoload/mq_user.php
+++ b/backend/config/autoload/mq_user.php
@@ -3,6 +3,7 @@
 declare(strict_types=1);
 
 use Hyperf\DbConnection\Db;
+use function Hyperf\Support\env;
 
 /**
  * RabbitMQ 用户配置
@@ -18,7 +19,7 @@ use Hyperf\DbConnection\Db;
 return [
     // 消费者用户
     'consumer' => [
-        'user' => 'user_dataflow_consumer',
+        'user' => 'user_datahub_consumer',
         'password' => env('MQ_PASSWORD_CONSUMER', ''),
     ],