Struct TransactionMQProducer 

pub struct TransactionMQProducer { /* private fields */ }

Implementations

impl TransactionMQProducer

pub fn builder( client_runtime: Arc<ClientRuntime>, ) -> TransactionMQProducerBuilder

pub fn client_session(&self) -> Option<&ClientSession>

pub async fn start(&mut self) -> ClientResult<()>

pub async fn shutdown(&mut self)

pub async fn send_message_in_transaction<T, M>( &self, msg: M, arg: Option<T>, ) -> ClientResult<TransactionSendResult>

where T: Any + Sync + Send, M: MessageTrait + Send + Sync,

pub fn set_transaction_listener( &mut self, transaction_listener: impl TransactionListener, )

pub fn transaction_listener(&self) -> Option<ArcTransactionListener>

pub fn get_transaction_listener(&self) -> Option<ArcTransactionListener>

pub fn transaction_check_listener(&self) -> Option<ArcTransactionListener>

pub fn get_transaction_check_listener(&self) -> Option<ArcTransactionListener>

pub fn set_transaction_check_listener( &mut self, transaction_check_listener: impl TransactionListener, )

pub fn set_transaction_check_listener_arc( &mut self, transaction_check_listener: ArcTransactionListener, )

pub fn set_transaction_listener_arc( &mut self, transaction_listener: ArcTransactionListener, )

pub fn check_thread_pool_min_size(&self) -> u32

pub fn get_check_thread_pool_min_size(&self) -> u32

pub fn set_check_thread_pool_min_size( &mut self, check_thread_pool_min_size: u32, )

pub fn check_thread_pool_max_size(&self) -> u32

pub fn get_check_thread_pool_max_size(&self) -> u32

pub fn set_check_thread_pool_max_size( &mut self, check_thread_pool_max_size: u32, )

pub fn check_request_hold_max(&self) -> u32

pub fn get_check_request_hold_max(&self) -> u32

pub fn set_check_request_hold_max(&mut self, check_request_hold_max: u32)

pub fn is_use_tls(&self) -> bool

pub fn set_use_tls(&mut self, use_tls: bool)

Trait Implementations

impl ClientSessionProvider for TransactionMQProducer

fn client_session(&self) -> Option<&ClientSession>

impl MessageQuery for TransactionMQProducer

async fn query( &mut self, request: ProducerQueryRequest, ) -> ClientResult<ProducerQueryResponse>

Executes one producer query.

impl MessageRecall for TransactionMQProducer

async fn recall(&mut self, request: RecallRequest) -> ClientResult<String>

Recalls one message.

impl MessageSend for TransactionMQProducer

async fn send_message<M>( &mut self, request: SendRequest<M>, ) -> ClientResult<Option<SendResult>>

where M: MessageTrait + Send + Sync,

Sends one message using a closed request contract.

async fn send_message_batch<M>( &mut self, request: BatchSendRequest<M>, ) -> ClientResult<SendResult>

where M: MessageTrait + Send + Sync,

Sends a batch using a closed request contract.

async fn send_message_with_callback<M>( &mut self, request: SendCallbackRequest<M>, ) -> ClientResult<()>

where M: MessageTrait + Send + Sync,

Sends one message and reports completion through the supplied callback.

async fn send_selected<M, S, T>( &mut self, request: SelectedSendRequest<M, S, T>, ) -> ClientResult<Option<SendResult>>

where M: MessageTrait + Send + Sync, S: Fn(&[MessageQueue], &M, &T) -> Option<MessageQueue> + Send + Sync + 'static, T: Send + Sync + 'static,

Sends one message using a queue selector.

async fn send_selected_with_callback<M, S, T>( &mut self, request: SelectedSendCallbackRequest<M, S, T>, ) -> ClientResult<()>

where M: MessageTrait + Send + Sync, S: Fn(&[MessageQueue], &M, &T) -> Option<MessageQueue> + Send + Sync + 'static, T: Send + Sync + 'static,

Sends one selected message and reports completion through a callback.

async fn send_message_batch_with_callback<M>( &mut self, request: BatchSendCallbackRequest<M>, ) -> ClientResult<()>

where M: MessageTrait + Send + Sync,

Sends a batch and reports completion through a callback.

impl ProducerLifecycle for TransactionMQProducer

async fn start_producer(&mut self) -> ClientResult<()>

Starts the producer.

async fn shutdown_producer(&mut self)

Shuts down producer-owned work.

impl ProducerTopicAdmin for TransactionMQProducer

async fn create_topic_request( &mut self, request: TopicCreateRequest, ) -> ClientResult<()>

Creates a topic through the producer’s existing admin facade.

impl RequestReply for TransactionMQProducer

async fn request_reply<M>( &mut self, request: RequestReplyRequest<M>, ) -> ClientResult<Box<dyn MessageTrait + Send>>

where M: MessageTrait + Send + Sync,

Sends a request and waits for its correlated reply.

async fn request_reply_with_callback<M>( &mut self, request: RequestReplyCallbackRequest<M>, ) -> ClientResult<()>

where M: MessageTrait + Send + Sync,

Sends a request and reports its correlated reply through a callback.

async fn request_reply_selected<M, S, T>( &mut self, request: SelectedRequestReplyRequest<M, S, T>, ) -> ClientResult<Box<dyn MessageTrait + Send>>

where M: MessageTrait + Send + Sync, S: Fn(&[MessageQueue], &M, &T) -> Option<MessageQueue> + Send + Sync + 'static, T: Send + Sync + 'static,

Sends a selector-routed request and waits for its reply.

async fn request_reply_selected_with_callback<M, S, T>( &mut self, request: SelectedRequestReplyCallbackRequest<M, S, T>, ) -> ClientResult<()>

where M: MessageTrait + Send + Sync, S: Fn(&[MessageQueue], &M, &T) -> Option<MessageQueue> + Send + Sync + 'static, T: Send + Sync + 'static,

Sends a selector-routed request and reports its reply through a callback.

impl TransactionSend for TransactionMQProducer

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.