Skip to content

Commit

Permalink
[ISSUE #641]🎨Optimize ProducerManager#unregister_producer (#642)
Browse files Browse the repository at this point in the history
  • Loading branch information
flydream-ylgw authored Jun 16, 2024
1 parent f04bab6 commit 7f0c5ad
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion rocketmq-broker/src/client/manager/producer_manager.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 7f0c5ad

Please # to comment.