[ISSUE #1310]⚡️Refactor AllocateMessageQueueStrategy (#1311)

Author: mxsm

rocketmq-client/src/consumer/allocate_message_queue_strategy.rs

@@ -22,8 +22,8 @@ use crate::Result;
 pub trait AllocateMessageQueueStrategy: Send + Sync {
     fn allocate(
         &self,
-        consumer_group: &str,
-        current_cid: &str,
+        consumer_group: &CheetahString,
+        current_cid: &CheetahString,
         mq_all: &[MessageQueue],
         cid_all: &[CheetahString],
     ) -> Result<Vec<MessageQueue>>;

rocketmq-client/src/consumer/rebalance_strategy/allocate_message_queue_averagely.rs

@@ -26,8 +26,8 @@ pub struct AllocateMessageQueueAveragely;
 impl AllocateMessageQueueStrategy for AllocateMessageQueueAveragely {
     fn allocate(
         &self,
-        consumer_group: &str,
-        current_cid: &str,
+        consumer_group: &CheetahString,
+        current_cid: &CheetahString,
         mq_all: &[MessageQueue],
         cid_all: &[CheetahString],
     ) -> Result<Vec<MessageQueue>> {