Skip to content

Commit cbf6b97

Browse files
authored
[ISSUE #6450]Remove useless code from pull_message_processor.rs (#6524)
* issue-6450 * issue-6450 * issue-6450 * issue-6450 * issue-6450 * issue-6450
1 parent fc1ee91 commit cbf6b97

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

rocketmq-broker/src/out_api/broker_outer_api.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -733,6 +733,7 @@ impl BrokerOuterAPI {
733733
ResponseCode::TopicNotExist if allow_topic_not_exist => {
734734
warn!("get Topic [{}] RouteInfoFromNameServer is not exist value", topic);
735735
}
736+
ResponseCode::TopicNotExist => {}
736737
ResponseCode::Success => {
737738
if let Some(body) = response.body() {
738739
let topic_route_data = TopicRouteData::decode(body).unwrap();

rocketmq-broker/src/processor/pull_message_processor.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -227,9 +227,7 @@ where
227227
let phy_queue_offset = mapping_item.compute_physical_queue_offset(global_offset);
228228
request_header.queue_id = phy_queue_id;
229229
request_header.queue_offset = phy_queue_offset;
230-
if mapping_item.check_if_end_offset_decided()
231-
/* && request_header.max_msg_nums.is_some() */
232-
{
230+
if mapping_item.check_if_end_offset_decided() {
233231
request_header.max_msg_nums = std::cmp::min(
234232
(mapping_item.end_offset - mapping_item.start_offset) as i32,
235233
request_header.max_msg_nums,

0 commit comments

Comments
 (0)