From d63103133c0c61e649056eb1cad3786366a29490 Mon Sep 17 00:00:00 2001 From: mxsm Date: Mon, 25 Nov 2024 22:27:44 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#1310]=E2=9A=A1=EF=B8=8FRefactor=20All?= =?UTF-8?q?ocateMessageQueueStrategy?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/consumer/allocate_message_queue_strategy.rs | 4 ++-- .../rebalance_strategy/allocate_message_queue_averagely.rs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/rocketmq-client/src/consumer/allocate_message_queue_strategy.rs b/rocketmq-client/src/consumer/allocate_message_queue_strategy.rs index 3065b344..7033baa9 100644 --- a/rocketmq-client/src/consumer/allocate_message_queue_strategy.rs +++ b/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>; diff --git a/rocketmq-client/src/consumer/rebalance_strategy/allocate_message_queue_averagely.rs b/rocketmq-client/src/consumer/rebalance_strategy/allocate_message_queue_averagely.rs index ce0b2ed4..432be955 100644 --- a/rocketmq-client/src/consumer/rebalance_strategy/allocate_message_queue_averagely.rs +++ b/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> {