blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2020-02-27 dd9fd78aec975c29d6c5ea4c802aca2b7f773d91 
 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());



            }



         }



   }