From 79a345a934bd1d42cc6d16f3f15e65572b1c6e0d Mon Sep 17 00:00:00 2001 From: mxsm Date: Mon, 25 Nov 2024 22:33:46 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#1310]=E2=9A=A1=EF=B8=8FRefactor=20All?= =?UTF-8?q?ocateMessageQueueStrategy=20(#1311)?= 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> {