Merge pull request #419 from dromara/dev

Dev To Master
dromara · Apr 11, 2024 · 3c41ef1 · 3c41ef1
2 parents 0f2801c + df080bd
commit 3c41ef1
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...ter-rocketmq/src/main/java/org/dromara/dynamictp/adapter/rocketmq/RocketMqDtpAdapter.java b/...ter-rocketmq/src/main/java/org/dromara/dynamictp/adapter/rocketmq/RocketMqDtpAdapter.java
@@ -31,6 +31,7 @@
 import org.dromara.dynamictp.common.util.ReflectionUtil;
 import org.dromara.dynamictp.core.support.ThreadPoolExecutorProxy;
 import org.dromara.dynamictp.jvmti.JVMTI;
+import org.springframework.util.ReflectionUtils;
 
 import java.util.Objects;
 import java.util.concurrent.ThreadPoolExecutor;
@@ -102,6 +103,9 @@ public void adaptProducerExecutors() {
             return;
         }
         for (DefaultMQProducer defaultMQProducer : beans) {
+            if (Objects.isNull(ReflectionUtils.findMethod(DefaultMQProducerImpl.class, "getAsyncSenderExecutor"))) {
+                continue;
+            }
             val producer = (DefaultMQProducerImpl) ReflectionUtil.getFieldValue(DefaultMQProducer.class,
                     "defaultMQProducerImpl", defaultMQProducer);
             if (Objects.isNull(producer)) {