(rocketmq-spring) branch master updated: feat:Modify the inner class call to use the bean instance invocation method (#687)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new b2717f3  feat:Modify the inner class call to use the bean instance 
invocation method (#687)
b2717f3 is described below

commit b2717f32c63a396ca00eb8899e7402bccb4039df
Author: fizz <54924160+whyst...@users.noreply.github.com>
AuthorDate: Mon Dec 16 14:28:14 2024 +0800

    feat:Modify the inner class call to use the bean instance invocation method 
(#687)
---
 .../rocketmq/spring/support/DefaultRocketMQListenerContainer.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
index e632fbc..c3bf81b 100644
--- 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
+++ 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
@@ -429,7 +429,8 @@ public class DefaultRocketMQListenerContainer implements 
InitializingBean,
                 log.debug("received msg: {}", messageExt);
                 try {
                     long now = System.currentTimeMillis();
-                    handleMessage(messageExt);
+                    DefaultRocketMQListenerContainer container = 
applicationContext.getBean(name, DefaultRocketMQListenerContainer.class);
+                    container.handleMessage(messageExt);
                     long costTime = System.currentTimeMillis() - now;
                     log.debug("consume {} cost: {} ms", messageExt.getMsgId(), 
costTime);
                 } catch (Exception e) {
@@ -452,7 +453,8 @@ public class DefaultRocketMQListenerContainer implements 
InitializingBean,
                 log.debug("received msg: {}", messageExt);
                 try {
                     long now = System.currentTimeMillis();
-                    handleMessage(messageExt);
+                    DefaultRocketMQListenerContainer container = 
applicationContext.getBean(name, DefaultRocketMQListenerContainer.class);
+                    container.handleMessage(messageExt);
                     long costTime = System.currentTimeMillis() - now;
                     log.debug("consume {} cost: {} ms", messageExt.getMsgId(), 
costTime);
                 } catch (Exception e) {