商城后台编辑

yujian

2019-11-11 3ce9e928e082ff8abf697dba560cbfbb412e89f8

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java

@@ -40,7 +40,7 @@


   @Override

   public Action consume(Message message, ConsumeContext context) {

      LogHelper.mqInfo("consumer-RedPackMessageListener", message.getTopic(), message.getTag(),

      LogHelper.mqInfo("consumer-RedPackMessageListener",message.getMsgID(), message.getTopic(), message.getTag(),

            new String(message.getBody()));

      String tag = message.getTag();

      if (tag == null)