You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/02/23 09:11:50 UTC
[GitHub] [rocketmq-client-go] duffiye opened a new issue #430: 延迟队列DelayTimeLevel不生效
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:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-go] ShannonDing closed issue #430: [Master]delay
order DelayTimeLevel not working
Posted by GitBox <gi...@apache.org>.
ShannonDing closed issue #430: [Master]delay order DelayTimeLevel not working
URL: https://github.com/apache/rocketmq-client-go/issues/430
----------------------------------------------------------------
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:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-go] duffiye commented on issue #430: delay order
DelayTimeLevel not working
Posted by GitBox <gi...@apache.org>.
duffiye commented on issue #430: delay order DelayTimeLevel not working
URL: https://github.com/apache/rocketmq-client-go/issues/430#issuecomment-590068141
JAVA SDK work well, but not this
----------------------------------------------------------------
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:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-go] xujianhai666 commented on issue #430: delay
order DelayTimeLevel not working
Posted by GitBox <gi...@apache.org>.
xujianhai666 commented on issue #430: delay order DelayTimeLevel not working
URL: https://github.com/apache/rocketmq-client-go/issues/430#issuecomment-590051594
golang native or cpp based version ?@duffiye
----------------------------------------------------------------
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:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [rocketmq-client-go] duffiye commented on issue #430: delay order
DelayTimeLevel not working
Posted by GitBox <gi...@apache.org>.
duffiye commented on issue #430: delay order DelayTimeLevel not working
URL: https://github.com/apache/rocketmq-client-go/issues/430#issuecomment-590057710
> golang native or cpp based version ?@duffiye
cpp
----------------------------------------------------------------
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:
users@infra.apache.org
With regards,
Apache Git Services