[ISSUE #2398]🐛Fix GetMessageStatus judgement not incorret (#2399)

mxsm · Jan 24, 2025 · b1b31ac · b1b31ac
1 parent efa9df2
commit b1b31ac
Showing 1 changed file with 5 additions and 5 deletions.
diff --git 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 {