RocketMQ消息实体改造

admin

2019-11-02 5e8907f1797a0f2028ab0731755941cf9ff7fc08

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java

@@ -22,6 +22,7 @@
import com.yeshi.fanli.exception.money.OrderMoneySettleException;

import com.yeshi.fanli.exception.mq.MQUnSendInfoException;

import com.yeshi.fanli.exception.order.InviteOrderSubsidyException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService;

import com.yeshi.fanli.service.inter.order.InviteOrderSubsidyService;

import com.yeshi.fanli.service.inter.order.OrderMoneySettleService;

@@ -59,9 +60,11 @@
   @Override

   public Action consume(Message message, ConsumeContext context) {



      if (!Constant.IS_TASK) {// 非任务服务器不能消费消息

         return Action.ReconsumeLater;

      }

      // if (!Constant.IS_TASK) {// 非任务服务器不能消费消息

      // return Action.ReconsumeLater;

      // }

      LogHelper.mqInfo("consumer:InviteOrderSubsidyMessageListener", message.getTopic(), message.getTag(),

            new String(message.getBody()));



      if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {

         // 查询上级红包

@@ -148,7 +151,7 @@


      Message msg = new Message(MQTopicName.TOPIC_FANLI.name(), "delay", new Gson().toJson(dto).getBytes());

      msg.setKey(dto.getSourceType() + "_" + dto.getOrderId());

      long delayTime = System.currentTimeMillis() + 1000 * 60 * 60 * 24L * day;

      long delayTime = System.currentTimeMillis() + (Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 60 * 24L * day);

      msg.setStartDeliverTime(delayTime);

      SendResult sendResult = producer.send(msg);

      if (sendResult != null) {