yujian
2020-05-13 8b3c82c0788e23acd889e6f67a91c855693352fd
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());
            }
         }
   }