From 8b2191df2f7d94aa299bd43dcbe97c94e5a61bbd Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 20 十一月 2019 14:53:34 +0800 Subject: [PATCH] RocketMQ的消息整改 --- fanli/src/main/java/com/yeshi/fanli/log/LogHelper.java | 6 ++++++ 1 files changed, 6 insertions(+), 0 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/log/LogHelper.java b/fanli/src/main/java/com/yeshi/fanli/log/LogHelper.java index 1255855..5f090b5 100644 --- a/fanli/src/main/java/com/yeshi/fanli/log/LogHelper.java +++ b/fanli/src/main/java/com/yeshi/fanli/log/LogHelper.java @@ -94,6 +94,12 @@ String error = errorMsg + "\ntopic:" + topic + "\ntag:" + tag + "\nbody:" + data; mqLogger.error(error); } + + public static void mqInfo(String extraInfo,String msgId, String topic, String tag, Object data) { + String info = extraInfo+"\nmsgId:"+msgId + "\ntopic:" + topic + "\ntag:" + tag + "\nbody:" + data; + mqLogger.info(info); + } + /** * 鐧诲綍淇℃伅 -- Gitblit v1.8.0