fix

qianye1001 · qianye1001 · commit 4a84ab78b2ed · 2026-02-02T20:38:41.000+08:00
Change-Id: Ic25eceeb32a7486d154b382cc62fbf3df9e91571
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java
@@ -250,7 +250,7 @@ private boolean hasMsgFromQueue(String targetTopic, NotificationRequestHeader re
                 ConsumeQueueInterface queue = this.brokerController.getMessageStore().getConsumeQueue(targetTopic, queueId);
                 // If the ConsumeQueue doesn't exist, it's not readable.
                 if (queue == null) {
-                   return false;
+                    return false;
                 }
                 ReferredIterator<CqUnit> iterator = null;
                 try {

Original file line number	Diff line number	Diff line change
`@@ -250,7 +250,7 @@ private boolean hasMsgFromQueue(String targetTopic, NotificationRequestHeader re`
`250`	`250`	`ConsumeQueueInterface queue = this.brokerController.getMessageStore().getConsumeQueue(targetTopic, queueId);`
`251`	`251`	`// If the ConsumeQueue doesn't exist, it's not readable.`
`252`	`252`	`if (queue == null) {`
`253`		`- return false;`
	`253`	`+ return false;`
`254`	`254`	`}`
`255`	`255`	`ReferredIterator<CqUnit> iterator = null;`
`256`	`256`	`try {`