Set auto commit (alibaba#914)

CST11021 · Jul 11, 2019 · 5b29b73 · 5b29b73
1 parent 92ec70b
commit 5b29b73
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Consumer.java b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Consumer.java
@@ -40,7 +40,7 @@ public static void main(String[] args) throws MQClientException {
 
             @Override
             public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) {
-                context.setAutoCommit(false);
+                context.setAutoCommit(true);
                 System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
                 this.consumeTimes.incrementAndGet();
                 if ((this.consumeTimes.get() % 2) == 0) {