From fffc2d0d3da9665c511499aaf76b078557c88dac Mon Sep 17 00:00:00 2001
From: RockChinQ <1010553892@qq.com>
Date: Sun, 12 May 2024 17:11:02 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E5=90=AF=E5=8A=A8=E6=97=B6=E5=88=9B?=
 =?UTF-8?q?=E5=BB=BAstream?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/mq/redis.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/backend/mq/redis.go b/backend/mq/redis.go
index d4ae4cd..2f1a5ca 100644
--- a/backend/mq/redis.go
+++ b/backend/mq/redis.go
@@ -25,6 +25,7 @@ func NewRedisStreamMQ() *RedisStreamMQ {
 	// 检查流是否存在
 	client.XGroupCreateMkStream(context.Background(), viper.GetString("mq.redis.stream.publish_post"), "campux", "0")
 	client.XGroupCreateMkStream(context.Background(), viper.GetString("mq.redis.stream.new_post"), "campux", "0")
+	client.XGroupCreateMkStream(context.Background(), viper.GetString("mq.redis.stream.post_cancel"), "campux", "0")
 
 	return &RedisStreamMQ{
 		Client:            client,