yujian
2019-11-13 851e43f3d0a79154cb4dc3a55738a83a97797c2d
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());
            }
         }
   }