feat: 启动时创建stream

idoknow · May 12, 2024 · fffc2d0 · fffc2d0
1 parent 2934dbf
commit fffc2d0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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,