From 7d6748445617dea43bc8c2c0410292e2eb423dc1 Mon Sep 17 00:00:00 2001 From: Ji Juntao Date: Sun, 19 Mar 2023 14:56:52 +0800 Subject: [PATCH] [ISSUE #6390] Add break to the exception of WHEEL_TIMER_NOT_ENABLE. (#6394) --- .../apache/rocketmq/broker/processor/SendMessageProcessor.java | 1 + 1 file changed, 1 insertion(+) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java index 092db4ed56..9625689a8e 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java @@ -398,6 +398,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement response.setCode(ResponseCode.SYSTEM_ERROR); response.setRemark(String.format("accurate timer message is not enabled, timerWheelEnable is %s", this.brokerController.getMessageStoreConfig().isTimerWheelEnable())); + break; case SERVICE_NOT_AVAILABLE: response.setCode(ResponseCode.SERVICE_NOT_AVAILABLE); response.setRemark(