From fa669594a4202d5f6481be62194cb81cf564281a Mon Sep 17 00:00:00 2001
From: nakul-py <nakulverma.py@gmail.com>
Date: Sat, 14 Dec 2024 20:33:55 +0530
Subject: [PATCH] Adding #[inline] for MQConsumerInnerImpl methods

---
 rocketmq-client/src/consumer/mq_consumer_inner.rs | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/rocketmq-client/src/consumer/mq_consumer_inner.rs b/rocketmq-client/src/consumer/mq_consumer_inner.rs
index 60764264..cef767fa 100644
--- a/rocketmq-client/src/consumer/mq_consumer_inner.rs
+++ b/rocketmq-client/src/consumer/mq_consumer_inner.rs
@@ -136,38 +136,47 @@ impl MQConsumerInnerImpl {
 }
 
 impl MQConsumerInner for MQConsumerInnerImpl {
+    #[inline]
     fn group_name(&self) -> CheetahString {
         MQConsumerInner::group_name(self.default_mqpush_consumer_impl.as_ref())
     }
 
+    #[inline]
     fn message_model(&self) -> MessageModel {
         MQConsumerInner::message_model(self.default_mqpush_consumer_impl.as_ref())
     }
 
+    #[inline]
     fn consume_type(&self) -> ConsumeType {
         MQConsumerInner::consume_type(self.default_mqpush_consumer_impl.as_ref())
     }
 
+    #[inline]
     fn consume_from_where(&self) -> ConsumeFromWhere {
         MQConsumerInner::consume_from_where(self.default_mqpush_consumer_impl.as_ref())
     }
 
+    #[inline]
     fn subscriptions(&self) -> HashSet<SubscriptionData> {
         MQConsumerInner::subscriptions(self.default_mqpush_consumer_impl.as_ref())
     }
 
+    #[inline]
     fn do_rebalance(&self) {
         MQConsumerInner::do_rebalance(self.default_mqpush_consumer_impl.as_ref())
     }
 
+    #[inline]
     async fn try_rebalance(&self) -> Result<bool> {
         MQConsumerInner::try_rebalance(self.default_mqpush_consumer_impl.as_ref()).await
     }
 
+    #[inline]
     async fn persist_consumer_offset(&self) {
         MQConsumerInner::persist_consumer_offset(self.default_mqpush_consumer_impl.as_ref()).await
     }
 
+    #[inline]
     async fn update_topic_subscribe_info(
         &self,
         topic: CheetahString,
@@ -181,6 +190,7 @@ impl MQConsumerInner for MQConsumerInnerImpl {
         .await
     }
 
+    #[inline]
     async fn is_subscribe_topic_need_update(&self, topic: &str) -> bool {
         MQConsumerInner::is_subscribe_topic_need_update(
             self.default_mqpush_consumer_impl.as_ref(),
@@ -189,10 +199,12 @@ impl MQConsumerInner for MQConsumerInnerImpl {
         .await
     }
 
+    #[inline]
     fn is_unit_mode(&self) -> bool {
         MQConsumerInner::is_unit_mode(self.default_mqpush_consumer_impl.as_ref())
     }
 
+    #[inline]
     fn consumer_running_info(&self) -> ConsumerRunningInfo {
         MQConsumerInner::consumer_running_info(self.default_mqpush_consumer_impl.as_ref())
     }