Struct Producer

pub struct Producer { /* private fields */ }

Producer is the core struct, to which application developers should turn, when publishing messages to RocketMQ proxy.

Producer is a thin wrapper of internal client struct that shoulders the actual workloads. Most of its methods take shared reference so that application developers may use it at will.

Producer is Send and Sync by design, so that developers may get started easily.

Implementations

impl Producer

pub fn new( option: ProducerOption, client_option: ClientOption, ) -> Result<Self, ClientError>

Create a new producer instance

Arguments

• option - producer option
• client_option - client option

pub fn new_transaction_producer( option: ProducerOption, client_option: ClientOption, transaction_checker: Box<TransactionChecker>, ) -> Result<Self, ClientError>

Create a new transaction producer instance

Arguments

• option - producer option
• client_option - client option
• transaction_checker - handle server query for uncommitted transaction status

pub async fn start(&mut self) -> Result<(), ClientError>

Start the producer

pub async fn send( &self, message: impl Message, ) -> Result<SendReceipt, ClientError>

Send a single message

Arguments

• message - the message to send

pub async fn batch_send( &self, messages: Vec<impl Message>, ) -> Result<Vec<SendReceipt>, ClientError>

Send a batch of messages

Arguments

• messages - A vector that holds the messages to send

pub async fn send_transaction_message( &self, message: impl Message, ) -> Result<impl Transaction, ClientError>

Send message in a transaction

pub async fn shutdown(self) -> Result<(), ClientError>

Trait Implementations

impl Debug for Producer

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

Formats the value using the given formatter.