yujian
2019-11-15 dbc8f0b2058d809e6dad0ada92d391109cbb4f57
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/token/InterTokenMessageListener.java
@@ -40,9 +40,6 @@
      String tag = message.getTag();
      if (tag == null)
         tag = "";
      BaseMQMsgBody baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class);
      if (baseBody.isTest() != Constant.IS_TEST)
         return Action.ReconsumeLater;
      if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
         if (tag.equalsIgnoreCase(UserTopicTagEnum.tokenOutOfDate.name())) {// 口令过期