Struct ClientConfig 

pub struct ClientConfig {

    pub namesrv_addr: Option<CheetahString>,
    pub client_ip: Option<CheetahString>,
    pub instance_name: CheetahString,
    pub client_callback_executor_threads: usize,
    pub namespace: Option<CheetahString>,
    pub namespace_initialized: Arc<AtomicBool>,
    pub namespace_v2: Option<CheetahString>,
    pub access_channel: AccessChannel,
    pub poll_name_server_interval: u32,
    pub heartbeat_broker_interval: u32,
    pub persist_consumer_offset_interval: u32,
    pub pull_time_delay_millis_when_exception: u32,
    pub unit_mode: bool,
    pub unit_name: Option<CheetahString>,
    pub decode_read_body: bool,
    pub decode_decompress_body: bool,
    pub vip_channel_enabled: bool,
    pub use_heartbeat_v2: bool,
    pub enable_concurrent_heartbeat: bool,
    pub use_tls: bool,
    pub socks_proxy_config: CheetahString,
    pub mq_client_api_timeout: u64,
    pub detect_timeout: u32,
    pub detect_interval: u32,
    pub language: LanguageCode,
    pub enable_stream_request_type: bool,
    pub send_latency_enable: bool,
    pub start_detector_enable: bool,
    pub enable_heartbeat_channel_event_listener: bool,
    pub enable_trace: bool,
    pub trace_topic: Option<CheetahString>,
    pub trace_msg_batch_num: usize,
    pub max_page_size_in_get_metadata: usize,
    pub concurrent_heartbeat_thread_pool_size: usize,
}

Fields

namesrv_addr: Option<CheetahString>

client_ip: Option<CheetahString>

instance_name: CheetahString

client_callback_executor_threads: usize

namespace: Option<CheetahString>

namespace_initialized: Arc<AtomicBool>

namespace_v2: Option<CheetahString>

access_channel: AccessChannel

poll_name_server_interval: u32

heartbeat_broker_interval: u32

persist_consumer_offset_interval: u32

pull_time_delay_millis_when_exception: u32

unit_mode: bool

unit_name: Option<CheetahString>

decode_read_body: bool

decode_decompress_body: bool

vip_channel_enabled: bool

use_heartbeat_v2: bool

enable_concurrent_heartbeat: bool

use_tls: bool

socks_proxy_config: CheetahString

mq_client_api_timeout: u64

detect_timeout: u32

detect_interval: u32

language: LanguageCode

enable_stream_request_type: bool

send_latency_enable: bool

start_detector_enable: bool

enable_heartbeat_channel_event_listener: bool

enable_trace: bool

trace_topic: Option<CheetahString>

trace_msg_batch_num: usize

max_page_size_in_get_metadata: usize

concurrent_heartbeat_thread_pool_size: usize

Thread pool size for concurrent heartbeat operations. Only effective when enable_concurrent_heartbeat is true. Default: number of CPU cores (matches Java: Runtime.getRuntime().availableProcessors())

Implementations

impl ClientConfig

pub const SEND_MESSAGE_WITH_VIP_CHANNEL_PROPERTY: &'static str = "com.rocketmq.sendMessageWithVIPChannel"

pub const SOCKS_PROXY_CONFIG: &'static str = "com.rocketmq.socks.proxy.config"

pub const DECODE_READ_BODY: &'static str = "com.rocketmq.read.body"

pub const DECODE_DECOMPRESS_BODY: &'static str = "com.rocketmq.decompress.body"

pub const SEND_LATENCY_ENABLE: &'static str = "com.rocketmq.sendLatencyEnable"

pub const START_DETECTOR_ENABLE: &'static str = "com.rocketmq.startDetectorEnable"

pub const HEART_BEAT_V2: &'static str = "com.rocketmq.heartbeat.v2"

pub const ENABLE_CONCURRENT_HEARTBEAT: &'static str = "com.rocketmq.enableConcurrentHeartbeat"

pub fn new() -> Self

impl ClientConfig

pub fn with_namespace( &mut self, resource: impl Into<CheetahString>, ) -> CheetahString

pub fn queue_with_namespace(&mut self, queue: MessageQueue) -> MessageQueue

pub fn get_namespace(&mut self) -> Option<CheetahString>

pub fn change_instance_name_to_pid(&mut self)

pub fn set_instance_name(&mut self, instance_name: CheetahString)

pub fn set_namesrv_addr(&mut self, namesrv_addr: CheetahString)

pub fn build_mq_client_id(&self) -> String

pub fn get_namesrv_addr(&self) -> Option<CheetahString>

pub fn get_client_ip(&self) -> Option<&CheetahString>

pub fn set_client_ip(&mut self, client_ip: CheetahString)

pub fn get_instance_name(&self) -> &CheetahString

pub fn get_client_callback_executor_threads(&self) -> usize

pub fn set_client_callback_executor_threads(&mut self, threads: usize)

pub fn get_namespace_v2(&self) -> Option<&CheetahString>

pub fn set_namespace_v2(&mut self, namespace_v2: CheetahString)

pub fn set_namespace(&mut self, namespace: CheetahString)

pub fn get_access_channel(&self) -> AccessChannel

pub fn set_access_channel(&mut self, access_channel: AccessChannel)

pub fn get_poll_name_server_interval(&self) -> u32

pub fn set_poll_name_server_interval(&mut self, interval: u32)

pub fn get_heartbeat_broker_interval(&self) -> u32

pub fn set_heartbeat_broker_interval(&mut self, interval: u32)

pub fn get_persist_consumer_offset_interval(&self) -> u32

pub fn set_persist_consumer_offset_interval(&mut self, interval: u32)

pub fn get_pull_time_delay_millis_when_exception(&self) -> u32

pub fn set_pull_time_delay_millis_when_exception(&mut self, delay: u32)

pub fn get_unit_name(&self) -> Option<&CheetahString>

pub fn set_unit_name(&mut self, unit_name: CheetahString)

pub fn is_unit_mode(&self) -> bool

pub fn set_unit_mode(&mut self, unit_mode: bool)

pub fn is_decode_read_body(&self) -> bool

pub fn set_decode_read_body(&mut self, decode_read_body: bool)

pub fn is_decode_decompress_body(&self) -> bool

pub fn set_decode_decompress_body(&mut self, decode_decompress_body: bool)

pub fn is_vip_channel_enabled(&self) -> bool

pub fn set_vip_channel_enabled(&mut self, enabled: bool)

pub fn is_use_heartbeat_v2(&self) -> bool

pub fn set_use_heartbeat_v2(&mut self, use_heartbeat_v2: bool)

pub fn is_use_tls(&self) -> bool

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

pub fn get_socks_proxy_config(&self) -> &CheetahString

pub fn set_socks_proxy_config(&mut self, config: CheetahString)

pub fn get_language(&self) -> LanguageCode

pub fn set_language(&mut self, language: LanguageCode)

pub fn get_mq_client_api_timeout(&self) -> u64

pub fn set_mq_client_api_timeout(&mut self, timeout: u64)

pub fn get_detect_timeout(&self) -> u32

pub fn set_detect_timeout(&mut self, timeout: u32)

pub fn get_detect_interval(&self) -> u32

pub fn set_detect_interval(&mut self, interval: u32)

pub fn is_enable_stream_request_type(&self) -> bool

pub fn set_enable_stream_request_type(&mut self, enabled: bool)

pub fn is_send_latency_enable(&self) -> bool

pub fn set_send_latency_enable(&mut self, enabled: bool)

pub fn is_start_detector_enable(&self) -> bool

pub fn set_start_detector_enable(&mut self, enabled: bool)

pub fn is_enable_heartbeat_channel_event_listener(&self) -> bool

pub fn set_enable_heartbeat_channel_event_listener(&mut self, enabled: bool)

pub fn is_enable_trace(&self) -> bool

pub fn set_enable_trace(&mut self, enabled: bool)

pub fn get_trace_topic(&self) -> Option<&CheetahString>

pub fn set_trace_topic(&mut self, topic: CheetahString)

pub fn get_trace_msg_batch_num(&self) -> usize

pub fn set_trace_msg_batch_num(&mut self, num: usize)

pub fn get_max_page_size_in_get_metadata(&self) -> usize

pub fn set_max_page_size_in_get_metadata(&mut self, size: usize)

pub fn get_concurrent_heartbeat_thread_pool_size(&self) -> usize

pub fn set_concurrent_heartbeat_thread_pool_size(&mut self, size: usize)

pub fn clone_client_config(&self) -> Self

Clones the configuration

pub fn reset_client_config(&mut self, other: &ClientConfig)

Resets client config from another instance

pub fn without_namespace(&mut self, resource: &str) -> CheetahString

👎Deprecated:

Use with_namespace for namespace wrapping

Deprecated: Use with_namespace instead

pub fn builder() -> ClientConfigBuilder

Creates a new builder for constructing a ClientConfig with a fluent API

Example

use rocketmq_client_rust::base::client_config::ClientConfig;

let config = ClientConfig::builder()
    .namesrv_addr("localhost:9876")
    .instance_name("my_producer")
    .enable_tls(true)
    .build()
    .unwrap();

Trait Implementations

impl Clone for ClientConfig

fn clone(&self) -> ClientConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ClientConfig

fn default() -> Self

Returns the “default value” for a type.

impl Display for ClientConfig

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

Formats the value using the given formatter.