(rocketmq) branch develop updated: [ISSUE #10009] Convert internal-only public classes to inner classes and add null-check log (#10028)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 70834e3db5 [ISSUE #10009] Convert internal-only public classes to 
inner classes and add null-check log (#10028)
70834e3db5 is described below

commit 70834e3db57add0667e4581f1ea867d135eb0be4
Author: sinberCS <42942020+sinbe...@users.noreply.github.com>
AuthorDate: Fri Mar 13 15:35:40 2026 +0800

    [ISSUE #10009] Convert internal-only public classes to inner classes and 
add null-check log (#10028)
    
    Change-Id: I9cc200303d3278c2cf763b953dd1ccafff57bcd2
---
 .../rocketmq/broker/schedule/ScheduleMessageService.java     | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
index bec75fe2fb..8ba9834702 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
@@ -546,7 +546,7 @@ public class ScheduleMessageService extends ConfigManager {
         }
     }
 
-    public class HandlePutResultTask implements Runnable {
+    class HandlePutResultTask implements Runnable {
         private final int delayLevel;
 
         public HandlePutResultTask(int delayLevel) {
@@ -558,6 +558,12 @@ public class ScheduleMessageService extends ConfigManager {
             LinkedBlockingQueue<PutResultProcess> pendingQueue =
                 
ScheduleMessageService.this.deliverPendingTable.get(this.delayLevel);
 
+            // Check if the queue exists for the given level
+            if (pendingQueue == null) {
+                log.warn("No pending queue found for delay level: {}", 
this.delayLevel);
+                return;
+            }
+
             PutResultProcess putResultProcess;
             while ((putResultProcess = pendingQueue.peek()) != null) {
                 try {
@@ -599,7 +605,7 @@ public class ScheduleMessageService extends ConfigManager {
         }
     }
 
-    public class PutResultProcess {
+    class PutResultProcess {
         private String topic;
         private long offset;
         private long physicOffset;
@@ -824,7 +830,7 @@ public class ScheduleMessageService extends ConfigManager {
         }
     }
 
-    public enum ProcessStatus {
+    enum ProcessStatus {
         /**
          * In process, the processing result has not yet been returned.
          */