|
|
@@ -32,7 +32,7 @@ func OneCirclesActivityCoinAutoExchangeGreenEnergyConsume(queue md.MqQueue) { |
|
|
//1、将自己绑定到交换机上 |
|
|
//1、将自己绑定到交换机上 |
|
|
ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) |
|
|
ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) |
|
|
//2、取出数据进行消费 |
|
|
//2、取出数据进行消费 |
|
|
ch.Qos(1) |
|
|
|
|
|
|
|
|
ch.Qos(50) |
|
|
delivery := ch.Consume(queue.Name, false) |
|
|
delivery := ch.Consume(queue.Name, false) |
|
|
|
|
|
|
|
|
one_circles.Init(cfg.RedisAddr) |
|
|
one_circles.Init(cfg.RedisAddr) |
|
|
@@ -61,7 +61,7 @@ func OneCirclesActivityCoinAutoExchangeGreenEnergyConsume(queue md.MqQueue) { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func handleOneCirclesActivityCoinAutoExchangeGreenEnergyConsume(msgData []byte) error { |
|
|
func handleOneCirclesActivityCoinAutoExchangeGreenEnergyConsume(msgData []byte) error { |
|
|
time.Sleep(time.Duration(2) * time.Millisecond) //休眠2毫秒 |
|
|
|
|
|
|
|
|
time.Sleep(time.Duration(1) * time.Millisecond) //休眠1毫秒 |
|
|
//1、解析mq中queue的数据结构体 |
|
|
//1、解析mq中queue的数据结构体 |
|
|
var msg *md2.OneCirclesStructForAutoExchangeGreenEnergy |
|
|
var msg *md2.OneCirclesStructForAutoExchangeGreenEnergy |
|
|
err := json.Unmarshal(msgData, &msg) |
|
|
err := json.Unmarshal(msgData, &msg) |
|
|
|
