lims_adapter/boot/nsq.go

package boot

import (
	"dashoo.cn/micro_libary/nsq"
	"github.com/gogf/gf/frame/g"
	"lims_adapter/service/reservation"
)

// NsqInit  nsq初始化
func NsqInit() {
	// 生产者初始化
	nsq.NSqProducer = nsq.NewNsqProducer()

	// 预约消息订阅
	autoProcessTopic := g.Cfg().GetString("nsq.nsqReservationAutoProcess")
	if autoProcessTopic != "" {
		go reservation.ReceiverReservation(autoProcessTopic)
	}
}