Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

spring-cloud-starter-stream-rocketmq2023.0.1.0版本的延时消息不能被延时消费 #3912

Closed
Dynasty-develop opened this issue Nov 29, 2024 · 3 comments

Comments

@Dynasty-develop
Copy link

Dynasty-develop commented Nov 29, 2024

BUG REPORT

Please describe the issue you observed:
What did you do (The steps to reproduce)?
使用rocketmq的5.x版本的客户端以及使用rocketmq5.x服务端,并在springCloudAlibaba微服务架构下使用rocketmq的自定义延时时间的延迟消息不能被延迟消费,而是会被立即被消费。原因是spring-cloud-starter-stream-rocketmq这个组件没有处理延时消息的属性TIMER_DELAY_SEC/TIMER_DELIVER_MS,直接被忽略掉了

What did you expect to see?
在client和server同为高版本的情况下,可以正常使用rocketmq提供的延时消息消费功能

Please tell us about your environment:
springcloud=2023.0.1
springcloudalibaba=2023.0.1.0
spring-cloud-starter-stream-rocketmq=2023.0.1.0
FEATURE REQUEST

Please describe the feature you are requesting.
发消息的时候带上延时消息的标识TIMER_DELAY_SEC/TIMER_DELIVER_MS时,消息会被立即消费

@w2dp
Copy link

w2dp commented Dec 12, 2024

分享一个临时解决办法。可以绕过

MessageConst.STRING_HASH_SET.remove(MessageConst.PROPERTY_TIMER_DELIVER_MS);

Copy link

This issue has been open 30 days with no activity. This will be closed in 7 days.

@github-actions github-actions bot added the stale label Jan 20, 2025
Copy link

This issue has been automatically marked as stale because it hasn't had any recent activity.If you think this should still be open, or the problem still persists, just pop a reply in the comments and one of the maintainers will (try!) to follow up. Thank you for your interest and contribution to the Sping Cloud Alibaba Community.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

3 participants