金币统计-mq

accompany-scheduler/accompany-scheduler-web/src/main/java/com/accompany/scheduler/config/RocketMQConfiguration.java

@@ -0,0 +1,24 @@
+package com.accompany.scheduler.config;
+
+import com.accompany.mq.producer.MQMessageProducer;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author: liaozetao
+ * @date: 2023/12/13 11:10
+ * @description:
+ */
+@Slf4j
+@Configuration
+@ConditionalOnClass(value = RocketMQTemplate.class)
+public class RocketMQConfiguration {
+
+    @Bean
+    public MQMessageProducer mqMessageProducer(RocketMQTemplate rocketMQTemplate) {
+        return new MQMessageProducer(rocketMQTemplate);
+    }
+}