blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yujian
2020-06-12 8a54915d3c39d9d8d7e90c0971d1e19d0eb76622 
 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());



            }



         }



   }