Struct TransactionMQProducerBuilder 

pub struct TransactionMQProducerBuilder { /* private fields */ }

Implementations

impl TransactionMQProducerBuilder

pub fn new(client_runtime: Arc<ClientRuntime>) -> Self

pub fn client_config(self, client_config: ClientConfig) -> Self

pub fn client_options(self, options: ClientOptions) -> Self

pub fn nameserver_discovery(self, discovery: NameServerDiscoveryConfig) -> Self

pub fn default_mqproducer_impl( self, default_mqproducer_impl: DefaultMQProducerImpl, ) -> Self

pub fn retry_response_codes(self, retry_response_codes: HashSet<i32>) -> Self

pub fn producer_group(self, producer_group: impl Into<CheetahString>) -> Self

pub fn topics(self, topics: Vec<impl Into<CheetahString>>) -> Self

pub fn name_server_addr( self, name_server_addr: impl Into<CheetahString>, ) -> Self

pub fn use_tls(self, use_tls: bool) -> Self

pub fn create_topic_key( self, create_topic_key: impl Into<CheetahString>, ) -> Self

pub fn default_topic_queue_nums(self, default_topic_queue_nums: u32) -> Self

pub fn send_msg_timeout(self, send_msg_timeout: u32) -> Self

pub fn compress_msg_body_over_howmuch( self, compress_msg_body_over_howmuch: u32, ) -> Self

pub fn retry_times_when_send_failed( self, retry_times_when_send_failed: u32, ) -> Self

pub fn retry_times_when_send_async_failed( self, retry_times_when_send_async_failed: u32, ) -> Self

pub fn retry_another_broker_when_not_store_ok( self, retry_another_broker_when_not_store_ok: bool, ) -> Self

pub fn max_message_size(self, max_message_size: u32) -> Self

pub fn trace_dispatcher(self, trace_dispatcher: ArcTraceDispatcher) -> Self

pub fn auto_batch(self, auto_batch: bool) -> Self

pub fn produce_accumulator( self, produce_accumulator: ProduceAccumulator, ) -> Self

pub fn enable_backpressure_for_async_mode( self, enable_backpressure_for_async_mode: bool, ) -> Self

pub fn back_pressure_for_async_send_num( self, back_pressure_for_async_send_num: u32, ) -> Self

pub fn back_pressure_for_async_send_size( self, back_pressure_for_async_send_size: u32, ) -> Self

pub fn rpc_hook(self, rpc_hook: Arc<dyn RPCHook>) -> Self

pub fn compress_level(self, compress_level: i32) -> Self

pub fn compress_type(self, compress_type: CompressionType) -> Self

pub fn compressor( self, compressor: &'static (dyn Compressor + Send + Sync), ) -> Self

pub fn transaction_listener( self, transaction_listener: impl TransactionListener, ) -> Self

pub fn check_thread_pool_max_size(self, size: u32) -> Self

Set maximum size of transaction check thread pool

Note: When using default Tokio Runtime with spawn_blocking, this serves as a reference. To control actual thread count, configure the Runtime:

tokio::runtime::Builder::new_multi_thread()
    .max_blocking_threads(100)
    .build()

pub fn check_thread_pool_min_size(self, size: u32) -> Self

Set minimum size of transaction check thread pool

pub fn check_request_hold_max(self, size: u32) -> Self

Set maximum capacity of transaction check request queue

pub fn build(self) -> TransactionMQProducer