RocketMQProducer.java 529 B

123456789101112131415161718
  1. package com.ruoyi.monitorInterface.mq;//package com.ruoyi.monitorInterface.mq;
  2. //
  3. //import org.apache.rocketmq.spring.core.RocketMQTemplate;
  4. //import org.springframework.beans.factory.annotation.Autowired;
  5. //import org.springframework.stereotype.Component;
  6. //
  7. //@Component
  8. //public class RocketMQProducer {
  9. //
  10. // @Autowired
  11. // private RocketMQTemplate rocketMQTemplate;
  12. //
  13. // // 发送消息
  14. // public void sendMessage(String topic, String msg) {
  15. // rocketMQTemplate.convertAndSend(topic, msg);
  16. // }
  17. //
  18. //}