【代码优化】IoT: 数据桥梁的执行器根据引入的消息队列动态加载

yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotKafkaMQDataBridgeExecute.java

@@ -22,7 +22,7 @@ import java.util.concurrent.TimeUnit;
  *
  * @author HUIHUI
  */
-@ConditionalOnClass(KafkaTemplate.class)
+@ConditionalOnClass(name = "org.springframework.kafka.core.KafkaTemplate")
 @Component
 @Slf4j
 public class IotKafkaMQDataBridgeExecute extends

yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotRabbitMQDataBridgeExecute.java

@@ -18,7 +18,7 @@ import java.time.LocalDateTime;
  *
  * @author HUIHUI
  */
-@ConditionalOnClass(Channel.class)
+@ConditionalOnClass(name = "com.rabbitmq.client.Channel")
 @Component
 @Slf4j
 public class IotRabbitMQDataBridgeExecute extends

yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotRocketMQDataBridgeExecute.java

@@ -19,7 +19,7 @@ import java.time.LocalDateTime;
  *
  * @author HUIHUI
  */
-@ConditionalOnClass(DefaultMQProducer.class)
+@ConditionalOnClass(name = "org.apache.rocketmq.client.producer.DefaultMQProducer")
 @Component
 @Slf4j
 public class IotRocketMQDataBridgeExecute extends