Skip to main content

TransactionSend

rocketmq_client_rust

Trait TransactionSend 

Source 
pub trait TransactionSend {
    // Required method
    async fn send_transaction<M, T>(
        &mut self,
        request: TransactionSendRequest<M, T>,
    ) -> ClientResult<TransactionSendResult>
       where M: MessageTrait + Send + Sync,
             T: Any + Send + Sync;
}
Expand description

Transactional send capability implemented only by transaction producers.

Required Methods§

Source

async fn send_transaction<M, T>( &mut self, request: TransactionSendRequest<M, T>, ) -> ClientResult<TransactionSendResult>
where M: MessageTrait + Send + Sync, T: Any + Send + Sync,

Sends a prepared message and executes the configured transaction listener.

§Errors

Returns the existing transaction listener, send, or end-transaction error.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§