//package com.yn.bftl.thirdparty.common.util;
//
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//
///**
// * rabbitmq工具类
// *
// * @author huabiao
// * @create 2021/5/13  14:28
// **/
//@Component
//public class RabbitTemplateUtils {
//
//    @Resource
//    private RabbitTemplate rabbitTemplate;
//
//    /**
//     * 延迟队列
//     *
//     * @param exchange
//     * @param routingKey
//     * @param data
//     * @param time
//     */
//    public void sendMessage(String exchange, String routingKey, final Object data, final String time) {
//        rabbitTemplate.convertAndSend(exchange, routingKey, data, message -> {
//            message.getMessageProperties().setExpiration(time);
//            return message;
//        });
//    }
//
//    /**
//     * 实时队列
//     *
//     * @param exchange
//     * @param routingKey
//     * @param data
//     */
//    public void sendMessage(String exchange, String routingKey, final Object data) {
//        rabbitTemplate.convertAndSend(exchange, routingKey, data);
//    }
//}
//
