yujian
2020-01-03 0a63d22e38a644bc83b393ed85618b04d3be858b
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());
            }
         }
   }