Closed mxsm closed 1 week ago
πThanks for your contributionπ. CodeRabbit(AI) will review your code firstπ₯
[!CAUTION]
Review failed
The pull request is closed.
The changes introduce a comprehensive set of features and enhancements to the RocketMQ client library, primarily focusing on the implementation of message consumption strategies. New modules and structures are added to facilitate concurrent and orderly message processing, along with configuration capabilities for consumers. Additionally, example implementations and improved organizational structures enhance the usability and maintainability of the codebase.
Files | Change Summary |
---|---|
rocketmq-client/Cargo.toml |
Added a new example entry for a consumer implementation. |
rocketmq-client/examples/quickstart/consumer.rs |
Introduced a new quickstart example for a message consumer using RocketMQ. |
rocketmq-client/src/base/access_channel.rs |
Added Default trait to AccessChannel enum, allowing a default value. |
rocketmq-client/src/consumer.rs |
Introduced several new public modules to enhance consumer functionality. |
rocketmq-client/src/consumer/allocate_message_queue_strategy.rs |
Defined a new trait for allocating message queues. |
rocketmq-client/src/consumer/consumer_impl.rs |
Added multiple new modules for various message consumption services. |
rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs |
Implemented a service for concurrent message consumption. |
rocketmq-client/src/consumer/consumer_impl/consume_message_orderly_service.rs |
Implemented a service for orderly message consumption. |
rocketmq-client/src/consumer/default_mq_push_consumer.rs |
Implemented the main consumer interface and configuration management. |
rocketmq-client/src/consumer/default_mq_push_consumer_builder.rs |
Introduced a builder pattern for constructing DefaultMQPushConsumer instances. |
rocketmq-client/src/consumer/listener.rs |
Added several modules related to message consumption strategies. |
rocketmq-client/src/consumer/listener/consume_concurrently_context.rs |
Defined context management for concurrent message consumption. |
rocketmq-client/src/consumer/listener/consume_orderly_context.rs |
Defined context management for orderly message consumption. |
rocketmq-client/src/consumer/listener/consume_concurrently_status.rs |
Introduced an enum for concurrent consumption statuses. |
rocketmq-client/src/consumer/listener/consume_orderly_status.rs |
Introduced an enum for orderly consumption statuses. |
Objective | Addressed | Explanation |
---|---|---|
Support client consumer message-1 (#960) | β |
π° "In the fields where messages flow,
New paths for consumers now brightly glow.
With context and status, they leap and play,
In orderly fashion, they find their way.
Hooray for the changes, let the messages sing,
A hop and a skip, oh what joy they bring!" πβ¨
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
Attention: Patch coverage is 0%
with 1335 lines
in your changes missing coverage. Please review.
Project coverage is 21.32%. Comparing base (
a707080
) to head (11ce097
). Report is 1 commits behind head on main.
:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.
Which Issue(s) This PR Fixes(Closes)
Fixes #960
Brief Description
How Did You Test This Change?
Summary by CodeRabbit
New Features
DefaultMQPushConsumer
.Bug Fixes
Documentation
Refactor