RabbitmqServiceImpl.java 1014 B

123456789101112131415161718192021222324252627282930313233343536373839404142434445
  1. package com.fjhx.rabbitmq.service.impl;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.fjhx.rabbitmq.RabbitMQProducer;
  4. import com.fjhx.rabbitmq.SdRabbitMQProducer;
  5. import com.fjhx.rabbitmq.service.RabbitmqService;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.stereotype.Service;
  8. /**
  9. * @Description:
  10. * @ClassName: RabbitmqServiceImpl
  11. * @Author: linqt
  12. * @Date: 2022/3/28 15:16
  13. * @Version: 1.0
  14. */
  15. @Service
  16. public class RabbitmqServiceImpl implements RabbitmqService {
  17. @Autowired
  18. private RabbitMQProducer rabbitMQProducer;
  19. @Autowired
  20. private SdRabbitMQProducer sdRabbitMQProducer;
  21. /**
  22. * 发送消息
  23. *
  24. * @param jsonObject
  25. */
  26. @Override
  27. public void send(JSONObject jsonObject) {
  28. rabbitMQProducer.send(jsonObject);
  29. }
  30. /**
  31. * 发送消息
  32. *
  33. * @param jsonObject
  34. */
  35. @Override
  36. public void sdSend(JSONObject jsonObject) {
  37. sdRabbitMQProducer.send(jsonObject);
  38. }
  39. }