From 7f0c5adc360951a4cbc5d90292a8d58fdcbe79fa Mon Sep 17 00:00:00 2001 From: flydream-ylgw <1944054640@qq.com> Date: Sun, 16 Jun 2024 15:40:08 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#641]=F0=9F=8E=A8Optimize=20ProducerMa?= =?UTF-8?q?nager#unregister=5Fproducer=20(#642)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rocketmq-broker/src/client/manager/producer_manager.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rocketmq-broker/src/client/manager/producer_manager.rs b/rocketmq-broker/src/client/manager/producer_manager.rs index dd46eb08..bfd0ba6f 100644 --- a/rocketmq-broker/src/client/manager/producer_manager.rs +++ b/rocketmq-broker/src/client/manager/producer_manager.rs @@ -48,7 +48,7 @@ impl ProducerManager { !channels.unwrap().is_empty() } - pub fn unregister_producer(&self, group: &String, client_channel_info: &ClientChannelInfo) { + pub fn unregister_producer(&self, group: &str, client_channel_info: &ClientChannelInfo) { let mut mutex_guard = self.group_channel_table.lock(); let channel_table = mutex_guard.get_mut(group); if let Some(ct) = channel_table {