RocketMQ消息改造

admin

2020-06-30 3eb64b02a585e6d385d09cd23e70e337b3ed4319

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

            }

         }

   }