Browse Source

update

three
DengBiao 1 year ago
parent
commit
e1cd7253ea
4 changed files with 6 additions and 0 deletions
  1. +1
    -0
      consume/dou_shen_user_register_for_my_my_fans.go
  2. +2
    -0
      consume/dou_shen_user_register_for_my_my_recommender.go
  3. +1
    -0
      consume/dou_shen_user_register_for_official_consume.go
  4. +2
    -0
      consume/dou_shen_user_register_for_operation_center.go

+ 1
- 0
consume/dou_shen_user_register_for_my_my_fans.go View File

@@ -54,6 +54,7 @@ func DouShenUserRegisterConsumeForMyFans(queue md.MqQueue) {
} }


func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error { func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error {
time.Sleep(time.Duration(3) * time.Second)
//1、解析mq中queue的数据结构体 //1、解析mq中queue的数据结构体
var msg *md.DouShenUserRegisterMessageStructForMyFans var msg *md.DouShenUserRegisterMessageStructForMyFans
err := json.Unmarshal(msgData, &msg) err := json.Unmarshal(msgData, &msg)


+ 2
- 0
consume/dou_shen_user_register_for_my_my_recommender.go View File

@@ -13,6 +13,7 @@ import (
"errors" "errors"
"fmt" "fmt"
"github.com/streadway/amqp" "github.com/streadway/amqp"
"time"
) )


func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) { func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) {
@@ -50,6 +51,7 @@ func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) {
} }


func handleDouShenUserRegisterConsumeForMyRecommender(msgData []byte) error { func handleDouShenUserRegisterConsumeForMyRecommender(msgData []byte) error {
time.Sleep(time.Duration(3) * time.Second)
//1、解析mq中queue的数据结构体 //1、解析mq中queue的数据结构体
var msg *md.DouShenUserRegisterMessageStructForMyRecommender var msg *md.DouShenUserRegisterMessageStructForMyRecommender
err := json.Unmarshal(msgData, &msg) err := json.Unmarshal(msgData, &msg)


+ 1
- 0
consume/dou_shen_user_register_for_official_consume.go View File

@@ -53,6 +53,7 @@ func DouShenUserRegisterConsumeForOfficial(queue md.MqQueue) {
} }


func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error { func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error {
time.Sleep(time.Duration(3) * time.Second)
//1、解析mq中queue的数据结构体 //1、解析mq中queue的数据结构体
var msg *md.DouShenUserRegisterMessageStructForOfficial var msg *md.DouShenUserRegisterMessageStructForOfficial
err := json.Unmarshal(msgData, &msg) err := json.Unmarshal(msgData, &msg)


+ 2
- 0
consume/dou_shen_user_register_for_operation_center.go View File

@@ -13,6 +13,7 @@ import (
"errors" "errors"
"fmt" "fmt"
"github.com/streadway/amqp" "github.com/streadway/amqp"
"time"
) )


func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) { func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) {
@@ -50,6 +51,7 @@ func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) {
} }


func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error { func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error {
time.Sleep(time.Duration(3) * time.Second)
//1、解析mq中queue的数据结构体 //1、解析mq中queue的数据结构体
var msg *md.DouShenUserRegisterMessageStructForOperationCenter var msg *md.DouShenUserRegisterMessageStructForOperationCenter
err := json.Unmarshal(msgData, &msg) err := json.Unmarshal(msgData, &msg)


Loading…
Cancel
Save