Commit fe3eb4a6 authored by yanzg's avatar yanzg

修改MQ请求尸体,防止出错

parent 5ff8c42a
......@@ -70,10 +70,13 @@ public class MqAspect extends BaseRequestAspect {
if (joinPoint.getSignature() instanceof MethodSignature) {
MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
Method targetMethod = methodSignature.getMethod();
if ("YzgMqConsumer".equals(targetMethod.getDeclaringClass().getSimpleName())) {
return false;
}
Annotation[] annotations = targetMethod.getAnnotations();
for (Annotation annotation : annotations) {
if (annotation.annotationType() != null
&& annotation.annotationType().getSimpleName().equals("RabbitListener")) {
&& "RabbitListener".equals(annotation.annotationType().getSimpleName())) {
return true;
}
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment