blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yujian
2020-04-02 0ec22dcf4fd9c4496e6f681e7fab89f56c6e4e8a 
 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());



            }



         }



   }