From 1a97226851d96b63efc739a1e053376e729ade88 Mon Sep 17 00:00:00 2001 From: yangy Date: Mon, 8 Jun 2020 11:06:42 +0800 Subject: [PATCH] Polish RocketMQ PullConsumerDemo to make code clear (#1528) --- .../csp/sentinel/demo/rocketmq/PullConsumerDemo.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/sentinel-demo/sentinel-demo-rocketmq/src/main/java/com/alibaba/csp/sentinel/demo/rocketmq/PullConsumerDemo.java b/sentinel-demo/sentinel-demo-rocketmq/src/main/java/com/alibaba/csp/sentinel/demo/rocketmq/PullConsumerDemo.java index 6435aca5..522c707f 100755 --- a/sentinel-demo/sentinel-demo-rocketmq/src/main/java/com/alibaba/csp/sentinel/demo/rocketmq/PullConsumerDemo.java +++ b/sentinel-demo/sentinel-demo-rocketmq/src/main/java/com/alibaba/csp/sentinel/demo/rocketmq/PullConsumerDemo.java @@ -76,14 +76,11 @@ public class PullConsumerDemo { putMessageQueueOffset(mq, nextOffset); consumer.updateConsumeOffset(mq, nextOffset); switch (pullResult.getPullStatus()) { - case FOUND: - break; - case NO_MATCHED_MSG: - break; case NO_NEW_MSG: break SINGLE_MQ; + case FOUND: + case NO_MATCHED_MSG: case OFFSET_ILLEGAL: - break; default: break; }