From d66465cd41510d4d7b65d868c5f166bbda8a541a Mon Sep 17 00:00:00 2001
From: yx-Yaoxaing <228649021@qq.com>
Date: Sat, 18 Nov 2023 14:18:09 +0800
Subject: [PATCH] Resolving consumer beans from CGLIB proxy classes created by
 @Configuration.

---
 .../annotation/RocketMQMessageListenerBeanPostProcessor.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListenerBeanPostProcessor.java b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListenerBeanPostProcessor.java
index 82269835..4cffceeb 100644
--- a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListenerBeanPostProcessor.java
+++ b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListenerBeanPostProcessor.java
@@ -48,7 +48,7 @@ public Object postProcessBeforeInitialization(Object bean, String beanName) thro
     @Override
     public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
         Class<?> targetClass = AopUtils.getTargetClass(bean);
-        RocketMQMessageListener ann = targetClass.getAnnotation(RocketMQMessageListener.class);
+        RocketMQMessageListener ann = AnnotationUtils.findAnnotation(targetClass, RocketMQMessageListener.class);
         if (ann != null) {
             RocketMQMessageListener enhance = enhance(targetClass, ann);
             if (listenerContainerConfiguration != null) {