MQ消费者拦截

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/aop/MqAspect.java

@@ -44,10 +44,11 @@ public class MqAspect extends BaseRequestAspect {
         Log.threadBegin();
         long start = System.currentTimeMillis();
         String name = joinPoint.getSignature().getName();
+        logger.info("[ {} ] request params is {}", name, joinPoint.getArgs());
         try {
             Object ret = executeMethod(joinPoint, name);
             long end = System.currentTimeMillis();
-            logger.error("[ {} ] time ({})ms,  result is {}", name, (end - start), ret);
+            logger.info("[ {} ] time ({})ms,  result is {}", name, (end - start), ret);
             return ret;
         } catch (Exception e) {
             long end = System.currentTimeMillis();