Browse Source

去除mq相关配置依赖

linhuili 3 years ago
parent
commit
79e3a6bde2

+ 0 - 1
scheduler/src/main/kotlin/cn/sagacloud/server/scheduler/service/ActiveMQConsumer.kt

@@ -1,6 +1,5 @@
 package cn.sagacloud.server.scheduler.service
 
-import org.springframework.jms.annotation.JmsListener
 import org.springframework.stereotype.Component
 import org.springframework.stereotype.Service
 

+ 2 - 7
scheduler/src/main/kotlin/cn/sagacloud/server/scheduler/service/JMSProducer.kt

@@ -1,17 +1,12 @@
 package cn.sagacloud.server.scheduler.service
 
-import com.alibaba.fastjson.JSON
-import org.apache.activemq.command.ActiveMQTopic
-import org.springframework.beans.factory.annotation.Autowired
-import org.springframework.jms.core.JmsMessagingTemplate
 import org.springframework.stereotype.Service
-import javax.jms.Destination
 
 
 @Service
 class JMSProducer {
 
-    @Autowired // 也可以注入JmsTemplate,JmsMessagingTemplate对JmsTemplate进行了封装
+    /*@Autowired // 也可以注入JmsTemplate,JmsMessagingTemplate对JmsTemplate进行了封装
     lateinit var jmsTemplate: JmsMessagingTemplate
 
     val destinationTest = ActiveMQTopic("mytest.topic")
@@ -19,7 +14,7 @@ class JMSProducer {
 
     fun sendMessage(message: String?) {
         jmsTemplate.convertAndSend(destination, message?:"")
-    }
+    }*/
 
 //    fun sendMessage(message: JSON) {
 //        jmsTemplate.convertAndSend(destination, message.toJSONString())