2.1需求

yujian

2020-05-09 7e7db2fa55a9a3af46d4fd8ede0dee147f101d64

 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());

            }

         }

   }