Struct MessageBatchV2 

pub struct MessageBatchV2 { /* private fields */ }

Batch message container

Used for sending multiple messages in batch. Requires all messages to have the same topic and send properties.

Constraints

• All messages must have the same topic
• All messages must have the same wait_store_msg_ok property
• Delayed messages are not supported
• Retry topics are not supported

Examples

use rocketmq_model::common::message::message_batch_v2::MessageBatchV2;
use rocketmq_model::common::message::message_single::Message;

let msg1 = Message::builder()
    .topic("TopicTest")
    .body_slice(b"Hello")
    .build_unchecked();
let msg2 = Message::builder()
    .topic("TopicTest")
    .body_slice(b"World")
    .build_unchecked();

let batch = MessageBatchV2::new(vec![msg1, msg2]).unwrap();
assert_eq!(batch.len(), 2);
assert_eq!(batch.topic().as_str(), "TopicTest");

Implementations

impl MessageBatchV2

pub fn new(messages: Vec<Message>) -> Result<Self>

Creates a batch message

Errors

• Message list is empty
• Messages have different topics
• Contains delayed messages
• Contains retry topics
• wait_store_msg_ok properties are inconsistent

pub fn topic(&self) -> &CheetahString

Gets the batch message topic

pub fn wait_store_msg_ok(&self) -> bool

Whether to wait for storage completion

pub fn len(&self) -> usize

Gets the number of batch messages

pub fn is_empty(&self) -> bool

Checks if the batch is empty

pub fn iter(&self) -> impl Iterator<Item = &Message>

Iterates over all messages

pub fn messages(&self) -> &[Message]

Gets a reference to the message list

pub fn into_messages(self) -> Vec<Message>

Consumes the batch and returns the internal message list

Trait Implementations

impl Clone for MessageBatchV2

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MessageBatchV2

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for MessageBatchV2

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl IntoIterator for MessageBatchV2

type IntoIter = IntoIter<Message>

Which kind of iterator are we turning this into?

type Item = Message

The type of the elements being iterated over.

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<'a> IntoIterator for &'a MessageBatchV2

type IntoIter = Iter<'a, Message>

Which kind of iterator are we turning this into?

type Item = &'a Message

The type of the elements being iterated over.

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.