15 lines
196 B
Go
15 lines
196 B
Go
|
package initalize
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fusenapi/utils/queue"
|
||
|
|
)
|
||
|
|
|
||
|
|
// 初始化
|
||
|
|
func InitDelayMessage() *queue.DelayMessage {
|
||
|
|
//创建延迟消息
|
||
|
|
dm := queue.NewDelayMessage()
|
||
|
|
|
||
|
|
go dm.Start()
|
||
|
|
return dm
|
||
|
|
}
|