blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2019-12-13 a3e7322a0aa6b5b13a84bc76923d0c6b68b13276 
 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());



            }



         }



   }