延时队列优化 （2）

@Bean("queueC")
    public Queue queueC()
    {
        HashMap<String, Object> args = new HashMap<String, Object>();
        args.put("x-dead-letter-exchange",Y_DEAD_LETTER_EXCHANGE);
        args.put("x-dead-letter-routing-key","YD");
        //在这里没有声明TTL属性
        return  QueueBuilder.durable(QUEUE_C).withArguments(args).build();
    }
    @Bean
    public Binding queueBindingX(@Qualifier("queueC") Queue queueC,@Qualifier("xExchange") DirectExchange exchange)
    {
        return BindingBuilder.bind(queueC).to(exchange).with("XC");
    }

@Slf4j
@RequestMapping("ttl")
@RestController
public class Produce01 {
    @Autowired
    private RabbitTemplate rabbitTemplate;
//    @GetMapping("sendMsg/{message}")
//    public void sendMsg(@PathVariable String message)
//    {
//
//        log.info("当前时间：{},发送一条消息给俩个TTL队列：{}", new Date(),message);
//        rabbitTemplate.convertAndSend("X","XA","消息来于10s"+message);
//        rabbitTemplate.convertAndSend("X","XB","消息来于40s"+message);
//    }
    @GetMapping("sendExpirationMsg/{message}/{ttlTime}")
    public void senMsg(@PathVariable String message,@PathVariable  String ttlTime)
    {
        log.info("当前时间：{},发送一条时长{}毫秒TTL信息给队列C:{}", new Date(),ttlTime, message);
        rabbitTemplate.convertAndSend("X","XC",message, correlationData ->{
            correlationData.getMessageProperties().setExpiration(ttlTime);
            return correlationData;
        });
    }
}

@Slf4j
@Component
public class Consumer {
    @RabbitListener(queues = "QD")
    public void receiveD(Message message, Channel channel)
    {
        String s = new String(message.getBody());
        log.info("当前时间{}，死信队列D接收到消息---->{}",new Date(),s);
    }
}