From b1b31ac3319178f1353f2cd415a8309fada6733e Mon Sep 17 00:00:00 2001 From: mxsm Date: Fri, 24 Jan 2025 17:46:54 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#2398]=F0=9F=90=9BFix=20GetMessageStat?= =?UTF-8?q?us=20judgement=20not=20incorret=20(#2399)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rocketmq-broker/src/processor/pop_message_processor.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/rocketmq-broker/src/processor/pop_message_processor.rs b/rocketmq-broker/src/processor/pop_message_processor.rs index bb81221e..35b7efd5 100644 --- a/rocketmq-broker/src/processor/pop_message_processor.rs +++ b/rocketmq-broker/src/processor/pop_message_processor.rs @@ -1053,11 +1053,11 @@ where queue_id, result_inner.message_queue_offset().clone(), ); - } else if (result_inner.status().is_none() - || result_inner.status().unwrap() == GetMessageStatus::NoMatchedMessage - || result_inner.status().unwrap() == GetMessageStatus::OffsetFoundNull - || result_inner.status().unwrap() == GetMessageStatus::MessageWasRemoving - || result_inner.status().unwrap() == GetMessageStatus::NoMatchedLogicQueue) + } else if (result_inner.status().is_some() + && (result_inner.status().unwrap() == GetMessageStatus::NoMatchedMessage + || result_inner.status().unwrap() == GetMessageStatus::OffsetFoundNull + || result_inner.status().unwrap() == GetMessageStatus::MessageWasRemoving + || result_inner.status().unwrap() == GetMessageStatus::NoMatchedLogicQueue)) && result_inner.next_begin_offset() > -1 { if is_order {