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

[Bug] LMQ did not support scheduled message #6779

Closed
3 tasks done
HScarb opened this issue May 21, 2023 · 0 comments · Fixed by #6780
Closed
3 tasks done

[Bug] LMQ did not support scheduled message #6779

HScarb opened this issue May 21, 2023 · 0 comments · Fixed by #6780
Labels

Comments

@HScarb
Copy link
Contributor

HScarb commented May 21, 2023

Before Creating the Bug Report

  • I found a bug, not just asking a question, which should be created in GitHub Discussions.

  • I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.

  • I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.

Runtime platform environment

Windows10

RocketMQ version

branch: develop

JDK Version

OpenJDK 1.8

Describe the Bug

When sending a scheduled message to LMQ, it will be immediately dispatched to LMQ and will be dispatched again when the scheduled time is reached.

Steps to Reproduce

  1. Start a consumer to consume a LMQ
  2. Send a message with delay level or delay time
  3. Wait and see the consumer consume the message

What Did You Expect to See?

The message will be consumed at the time I scheduled.

What Did You See Instead?

The message was consumed immediately, and will be consumed again at the time I scheduled.

Additional Context

The LMQ dispatch logic did not consider scheduled message.

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

Successfully merging a pull request may close this issue.

1 participant