优化代码
parent
1137e3e762
commit
dad68a925b
|
@ -34,11 +34,6 @@ class TalkMessageEvent
|
||||||
*/
|
*/
|
||||||
const EVENT_FRIEND_APPLY = 'event_friend_apply';
|
const EVENT_FRIEND_APPLY = 'event_friend_apply';
|
||||||
|
|
||||||
/**
|
|
||||||
* WebSocket 消息消费队列交换机名称
|
|
||||||
*/
|
|
||||||
const CONSUMER_MESSAGE_EXCHANGE = 'im.message.fanout';
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
|
|
|
@ -4,6 +4,7 @@ declare(strict_types=1);
|
||||||
|
|
||||||
namespace App\Process;
|
namespace App\Process;
|
||||||
|
|
||||||
|
use App\Constants\RedisSubscribeChan;
|
||||||
use App\Service\Message\SubscribeHandleService;
|
use App\Service\Message\SubscribeHandleService;
|
||||||
use Hyperf\Process\AbstractProcess;
|
use Hyperf\Process\AbstractProcess;
|
||||||
use Hyperf\Process\Annotation\Process;
|
use Hyperf\Process\Annotation\Process;
|
||||||
|
@ -19,7 +20,9 @@ class RedisWebsocketSubscribe extends AbstractProcess
|
||||||
*
|
*
|
||||||
* @var string[]
|
* @var string[]
|
||||||
*/
|
*/
|
||||||
private $chans = ['websocket'];
|
private $chans = [
|
||||||
|
RedisSubscribeChan::WEBSOCKET_CHAN
|
||||||
|
];
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var SubscribeHandleService
|
* @var SubscribeHandleService
|
||||||
|
|
Loading…
Reference in New Issue