Update rocketmq-broker/src/processor/pop_message_processor.rs

TeslaRustor · coderabbitai[bot] · web-flow · commit 5486d7054512 · 2024-12-13T11:21:53.000+08:00
Co-authored-by: coderabbitai[bot] &lt;136622811+coderabbitai[bot]@users.noreply.github.com&gt;
diff --git a/rocketmq-broker/src/processor/pop_message_processor.rs b/rocketmq-broker/src/processor/pop_message_processor.rs
@@ -383,9 +383,9 @@ mod tests {
         let queue_id = 1;
         manager.try_lock(&topic, &consumer_group, queue_id).await;
         tokio::time::sleep(tokio::time::Duration::from_millis(10)).await;
-        let removed_count = manager.clean_unused_locks(5).await;
-        assert_eq!(removed_count, 1);
-        let removed_count = manager.clean_unused_locks(15).await;
-        assert_eq!(removed_count, 0);
+        let remaining_count = manager.clean_unused_locks(5).await;
+        assert_eq!(remaining_count, 0);
+        let remaining_count = manager.clean_unused_locks(15).await;
+        assert_eq!(remaining_count, 0);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -383,9 +383,9 @@ mod tests {`
`383`	`383`	`let queue_id = 1;`
`384`	`384`	`manager.try_lock(&topic, &consumer_group, queue_id).await;`
`385`	`385`	`tokio::time::sleep(tokio::time::Duration::from_millis(10)).await;`
`386`		`- let removed_count = manager.clean_unused_locks(5).await;`
`387`		`- assert_eq!(removed_count, 1);`
`388`		`- let removed_count = manager.clean_unused_locks(15).await;`
`389`		`- assert_eq!(removed_count, 0);`
	`386`	`+ let remaining_count = manager.clean_unused_locks(5).await;`
	`387`	`+ assert_eq!(remaining_count, 0);`
	`388`	`+ let remaining_count = manager.clean_unused_locks(15).await;`
	`389`	`+ assert_eq!(remaining_count, 0);`
`390`	`390`	`}`
`391`	`391`	`}`