Struct MQClientInstance

pub struct MQClientInstance { /* private fields */ }

Implementations

impl MQClientInstance

pub fn new( client_config: ClientConfig, instance_index: i32, client_id: String, rpc_hook: Option<Arc<Box<dyn RPCHook>>>, ) -> Self

pub fn new_arc( client_config: ClientConfig, instance_index: i32, client_id: impl Into<CheetahString>, rpc_hook: Option<Arc<Box<dyn RPCHook>>>, ) -> ArcMut<MQClientInstance>

pub fn re_balance_immediately(&self)

pub fn re_balance_later(&self, delay_millis: Duration)

pub async fn start(&mut self, this: ArcMut<Self>) -> RocketMQResult<()>

pub async fn shutdown(&mut self)

pub async fn register_producer( &mut self, group: &str, producer: MQProducerInnerImpl, ) -> bool

pub async fn register_admin_ext( &mut self, group: &str, admin: MQAdminExtInnerImpl, ) -> bool

pub async fn update_topic_route_info_from_name_server(&mut self)

pub async fn update_topic_route_info_from_name_server_topic( &mut self, topic: &CheetahString, ) -> bool

pub async fn find_consumer_id_list( &mut self, topic: &CheetahString, group: &CheetahString, ) -> Option<Vec<CheetahString>>

pub async fn find_broker_addr_by_topic( &self, topic: &str, ) -> Option<CheetahString>

pub async fn update_topic_route_info_from_name_server_default( &mut self, topic: &CheetahString, is_default: bool, producer_config: Option<&Arc<ProducerConfig>>, ) -> bool

pub async fn persist_all_consumer_offset(&mut self)

pub async fn clean_offline_broker(&mut self)

pub async fn send_heartbeat_to_all_broker_with_lock(&mut self) -> bool

pub async fn send_heartbeat_to_all_broker_with_lock_v2( &mut self, is_rebalance: bool, ) -> bool

pub fn get_mq_client_api_impl(&self) -> ArcMut<MQClientAPIImpl>

pub async fn get_broker_name_from_message_queue( &self, message_queue: &MessageQueue, ) -> CheetahString

pub async fn find_broker_address_in_publish( &self, broker_name: &CheetahString, ) -> Option<CheetahString>

pub async fn send_heartbeat_to_broker( &self, id: u64, broker_name: &CheetahString, addr: &CheetahString, ) -> bool

pub async fn register_consumer( &mut self, group: &CheetahString, consumer: MQConsumerInnerImpl, ) -> bool

pub async fn check_client_in_broker(&mut self) -> RocketMQResult<()>

pub async fn do_rebalance(&mut self) -> bool

pub fn rebalance_later(&mut self, delay_millis: u64)

pub async fn find_broker_address_in_subscribe( &mut self, broker_name: &CheetahString, broker_id: u64, only_this_broker: bool, ) -> Option<FindBrokerResult>

pub async fn select_consumer(&self, group: &str) -> Option<MQConsumerInnerImpl>

pub async fn select_producer(&self, group: &str) -> Option<MQProducerInnerImpl>

pub async fn unregister_consumer(&mut self, group: impl Into<CheetahString>)

pub async fn unregister_producer(&mut self, group: impl Into<CheetahString>)

pub async fn unregister_admin_ext(&mut self, group: impl Into<CheetahString>)

pub async fn query_assignment( &mut self, topic: &CheetahString, consumer_group: &CheetahString, strategy_name: &CheetahString, message_model: MessageModel, timeout: u64, ) -> RocketMQResult<Option<HashSet<MessageQueueAssignment>>>

Queries the assignment for a given topic.

This function attempts to find the broker address for the specified topic. If the broker address is not found, it updates the topic route information from the name server and retries. If the broker address is found, it queries the assignment from the broker.

Arguments

• topic - A reference to a CheetahString representing the topic to query.
• consumer_group - A reference to a CheetahString representing the consumer group.
• strategy_name - A reference to a CheetahString representing the allocation strategy name.
• message_model - The message model to use for the query.
• timeout - The timeout duration for the query.

Returns

A Result containing an Option with a HashSet of MessageQueueAssignment if the query is successful, or an error if it fails.

pub async fn consume_message_directly( &self, message: MessageExt, consumer_group: &CheetahString, broker_name: Option<CheetahString>, ) -> Option<ConsumeMessageDirectlyResult>