红包封禁功能

yujian

2019-11-12 8f5ca1d337950be2a20cdb1a91a29a86fde1b07d

 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)