配置文件修改

admin

2019-11-23 51a4ff5d777028d52a19c314a99f796334cb7b51

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

            }

         }

   }