[GitHub] [rocketmq-client-go] duffiye opened a new issue #430: 延迟队列DelayTimeLevel不生效

[GitBox]

duffiye opened a new issue #430: 延迟队列DelayTimeLevel不生效
URL: https://github.com/apache/rocketmq-client-go/issues/430
 
 
   消息发送：
   `    
   
            producer.Start()
        defer producer.Shutdown()
   
        msg := &rocketmq.Message{Topic: topic, Body: message}
        if delayTimeLevel >= 0 {
                msg.DelayTimeLevel = delayTimeLevel
                fmt.Printf("msg:%v\n", msg)
        }
   
        r, err := producer.SendMessageOrderlyByShardingKey(
                msg, "ShardingKey")
        if err != nil {
                println("Send Orderly Message Error:", err)
                return err
        }`
   
   msg打印信息：
   `msg:[Topic: xft, Tags: , Keys: , Body: 30024, DelayTimeLevel: 7, Property: 
map[]]
   
   消费者这边实时收到了消息：
   [`Rocket MQ Result [status: SendOK, messageId: 
1E0578CE5F0D662DDA7274F912880006, offset: 0]
   A message received, MessageID:1E0578CE5F0D662DDA7274F912880006, Body:30024 
](url)

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services