18 lines
371 B
Go
18 lines
371 B
Go
package utils
|
|
|
|
import (
|
|
"base-service/pkg/queue"
|
|
)
|
|
|
|
const (
|
|
WecomStream = "stream:wecom"
|
|
WecomGroup = "group:wecom"
|
|
WecomConsumer = "consumer:wecom"
|
|
)
|
|
|
|
// 不能自动启动，有 redis 生命周期顺序问题
|
|
func InitQueue() {
|
|
go queue.StartWorker(WecomStream, WecomGroup, WecomConsumer)
|
|
// go queue.StartWorker(email.Stream, email.Group, email.Consumer)
|
|
}
|