rocketmq官方的Order Message Example的一些疑问?

新手上路,请多包涵

问题描述

在官网学习rocketmq的例子代码有疑问,链接:http://rocketmq.apache.org/do... 是 Subscription message sample code 里面多个if判断取模的结果到底是什么意思?

相关代码

// 请把代码文本粘贴到下方(请勿用图片代替代码)
consumer.registerMessageListener(new MessageListenerOrderly() {

        AtomicLong consumeTimes = new AtomicLong(0);
        @Override
        public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs,
                                                   ConsumeOrderlyContext context) {
            context.setAutoCommit(false);
            System.out.printf(Thread.currentThread().getName() + " Receive New Messages: " + msgs + "%n");
            this.consumeTimes.incrementAndGet();
            if ((this.consumeTimes.get() % 2) == 0) {
                return ConsumeOrderlyStatus.SUCCESS;
            } else if ((this.consumeTimes.get() % 3) == 0) {
                return ConsumeOrderlyStatus.ROLLBACK;
            } else if ((this.consumeTimes.get() % 4) == 0) {
                return ConsumeOrderlyStatus.COMMIT;
            } else if ((this.consumeTimes.get() % 5) == 0) {
                context.setSuspendCurrentQueueTimeMillis(3000);
                return ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;
            }
            return ConsumeOrderlyStatus.SUCCESS;

        }
    });

你期待的结果是什么?实际看到的错误信息又是什么?

请哪位大牛解释一下那些if判断取模的值到底是设什么意思,看了半天实在是想不明白,谢谢!

阅读 2.7k
1 个回答
新手上路,请多包涵

模拟状态吧。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题