|
@@ -131,7 +131,7 @@ func NatsInit() {
|
|
|
_ = Nats.Publish(m.Reply, b)
|
|
|
})
|
|
|
// 发布-订阅 模式,异步订阅 系统日志
|
|
|
- _, _ = Nats.Subscribe(conf.NatsSubj_Prefix+"ERP_AddSysLogs", func(m *nats.Msg) {
|
|
|
+ _, _ = Nats.QueueSubscribe(conf.NatsSubj_Prefix+"ERP_AddSysLogs", "ERP_AddSysLogs", func(m *nats.Msg) {
|
|
|
fmt.Printf("ERP_AddSysLogs message: %v\n", string(m.Data))
|
|
|
|
|
|
type T_S struct {
|
|
@@ -153,7 +153,7 @@ func NatsInit() {
|
|
|
|
|
|
})
|
|
|
// 发布-订阅 模式,异步订阅 用户日志
|
|
|
- _, _ = Nats.Subscribe(conf.NatsSubj_Prefix+"ERP_AddUserLogs", func(m *nats.Msg) {
|
|
|
+ _, _ = Nats.QueueSubscribe(conf.NatsSubj_Prefix+"ERP_AddUserLogs", "ERP_AddSysLogs", func(m *nats.Msg) {
|
|
|
fmt.Printf("ERP_AddUserLogs message: %v\n", string(m.Data))
|
|
|
|
|
|
type T_S struct {
|
|
@@ -175,7 +175,7 @@ func NatsInit() {
|
|
|
|
|
|
})
|
|
|
// 发布-订阅 模式,异步订阅 消息
|
|
|
- _, _ = Nats.Subscribe(conf.NatsSubj_Prefix+"ERP_AddNews", func(m *nats.Msg) {
|
|
|
+ _, _ = Nats.QueueSubscribe(conf.NatsSubj_Prefix+"ERP_AddNews", "ERP_AddNews", func(m *nats.Msg) {
|
|
|
fmt.Printf("ERP_AddNews message: %v\n", string(m.Data))
|
|
|
|
|
|
type T_S struct {
|