From dad68a925bef9d63ecb4663ac9aa1bdd684f818b Mon Sep 17 00:00:00 2001
From: gzydong <837215079@qq.com>
Date: Sun, 11 Jul 2021 21:10:54 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Constants/TalkMessageEvent.php      | 5 -----
 app/Process/RedisWebsocketSubscribe.php | 5 ++++-
 2 files changed, 4 insertions(+), 6 deletions(-)

diff --git a/app/Constants/TalkMessageEvent.php b/app/Constants/TalkMessageEvent.php
index a1c018c..d4c3909 100644
--- a/app/Constants/TalkMessageEvent.php
+++ b/app/Constants/TalkMessageEvent.php
@@ -34,11 +34,6 @@ class TalkMessageEvent
      */
     const EVENT_FRIEND_APPLY = 'event_friend_apply';
 
-    /**
-     * WebSocket 消息消费队列交换机名称
-     */
-    const CONSUMER_MESSAGE_EXCHANGE = 'im.message.fanout';
-
     /**
      * @return array
      */
diff --git a/app/Process/RedisWebsocketSubscribe.php b/app/Process/RedisWebsocketSubscribe.php
index 30812c0..893a269 100644
--- a/app/Process/RedisWebsocketSubscribe.php
+++ b/app/Process/RedisWebsocketSubscribe.php
@@ -4,6 +4,7 @@ declare(strict_types=1);
 
 namespace App\Process;
 
+use App\Constants\RedisSubscribeChan;
 use App\Service\Message\SubscribeHandleService;
 use Hyperf\Process\AbstractProcess;
 use Hyperf\Process\Annotation\Process;
@@ -19,7 +20,9 @@ class RedisWebsocketSubscribe extends AbstractProcess
      *
      * @var string[]
      */
-    private $chans = ['websocket'];
+    private $chans = [
+        RedisSubscribeChan::WEBSOCKET_CHAN
+    ];
 
     /**
      * @var SubscribeHandleService