Skip to content

Commit 536126f

Browse files
authored
[ISSUE #5981]🚀Add new message types and refactor message handling for improved structure and clarity (#5982)
1 parent d75a1f7 commit 536126f

File tree

8 files changed

+1784
-0
lines changed

8 files changed

+1784
-0
lines changed

rocketmq-common/src/common/message.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ use rocketmq_error::RocketMQResult;
2929

3030
pub mod message_accessor;
3131
pub mod message_batch;
32+
pub mod message_batch_v2;
3233
pub mod message_body;
3334
pub mod message_builder;
3435
pub mod message_client_ext;
@@ -45,6 +46,12 @@ pub mod message_queue_assignment;
4546
pub mod message_queue_for_c;
4647
pub mod message_single;
4748

49+
// New refactored message types
50+
pub mod broker_message;
51+
pub mod message_envelope;
52+
pub mod routing_context;
53+
pub mod storage_metadata;
54+
4855
/// This module defines the `MessageTrait` trait, which provides a flexible interface for working
4956
///
5057
/// with message objects in RocketMQ. It includes methods for managing message properties, keys,

0 commit comments

Comments
 (0)