MQ日志调整

admin

2019-11-08 15f831b6e153cedea957bd08802380759a234c6a

 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)