yujian
2020-04-14 c04a59775ee986f33fe19e21ae02cff9f6b002a7
fanli/src/main/java/com/yeshi/fanli/job/MQJob.java
@@ -53,7 +53,7 @@
            SendResult sendResult = producer.send(msg);
            if (sendResult != null) {
               mqUnSendInfoService.deleteByPrimaryKey(sendInfo.getId());
               LogHelper.mqInfo("消息重发成功", sendInfo.getTopic(), sendInfo.getTag(), sendInfo.getBody());
               LogHelper.mqInfo("消息重发成功",sendResult.getMessageId(), sendInfo.getTopic(), sendInfo.getTag(), sendInfo.getBody());
            }
         }
   }