RabbitMqUtil.java 545 B

12345678910111213141516171819
  1. package com.jy.business.config;
  2. import cn.hutool.extra.spring.SpringUtil;
  3. import lombok.NoArgsConstructor;
  4. import org.springframework.amqp.rabbit.core.RabbitTemplate;
  5. @NoArgsConstructor
  6. public class RabbitMqUtil {
  7. private static final RabbitTemplate rabbitTemplate = SpringUtil.getBean(RabbitTemplate.class);
  8. /**
  9. * 发送合同确认到账
  10. */
  11. public static void sendConfirmFundReceived(Long id) {
  12. rabbitTemplate.convertAndSend(RabbitConfig.JY_DIRECT_EXCHANGE, RabbitConfig.CONFIRM_RECEIVED_QUEUE, id);
  13. }
  14. }