diff --git a/CHANGELOG.md b/CHANGELOG.md index d2ae91226..9f777111a 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -25,6 +25,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Changed +- **chore(broker):** Remove commented-out dead logging code in `pull_request_hold_service.rs` ([#6579](https://github.com/mxsm/rocketmq-rust/issues/6579)) - **refactor(remoting/tools):** Return references from `TopicStatsTable::get_offset_table` and add `into_offset_table`/`get_offset_table_mut` to avoid unnecessary `HashMap` cloning in topic status flows - **refactor(common):** Rename foundational `MessageTrait` methods to the idiomatic Rust naming: `get_property` to `property` and `get_property_ref` to `property_ref` (other getters like `get_topic`, `get_flag`, etc.. will be renamed in subsequent commits) - **refactor(client):** Refactor `default_mq_producer::start` in `default_mq_producer.rs` removing repeated `as_mut().unwrap()`([#5576](https://github.com/mxsm/rocketmq-rust/issues/5576)) diff --git a/rocketmq-broker/src/long_polling/long_polling_service/pull_request_hold_service.rs b/rocketmq-broker/src/long_polling/long_polling_service/pull_request_hold_service.rs index 669dda53f..d45847b60 100644 --- a/rocketmq-broker/src/long_polling/long_polling_service/pull_request_hold_service.rs +++ b/rocketmq-broker/src/long_polling/long_polling_service/pull_request_hold_service.rs @@ -110,10 +110,6 @@ where } let topic = CheetahString::from(key_parts[0]); let queue_id = key_parts[1].parse::().unwrap(); - /*info!( - "check hold request, topic: {}, queue_id: {}", - topic, queue_id - );*/ let max_offset = self .broker_runtime_inner .message_store()