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)