Polish RocketMQ PullConsumerDemo to make code clear (alibaba#1528)

hughpearse · Jun 8, 2020 · 7e6c5e3 · 7e6c5e3
1 parent 09693fb
commit 7e6c5e3
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/...-demo-rocketmq/src/main/java/com/alibaba/csp/sentinel/demo/rocketmq/PullConsumerDemo.java b/...-demo-rocketmq/src/main/java/com/alibaba/csp/sentinel/demo/rocketmq/PullConsumerDemo.java
@@ -76,14 +76,11 @@ public static void main(String[] args) throws MQClientException {
                     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;
                     }