RabbitMQ 发送延时消息

public void sendDelay(String queueName,Long ttl,String msg){
        // 创建延迟交换机
        Map args = new HashMap<>();
        args.put("x-delayed-type", "direct");
        CustomExchange customExchange = new CustomExchange("plugDelayExchange", "x-delayed-message",true, false,args);
        areaRabbitAdmin.declareExchange(customExchange);
        // 创建消费队列
        Queue queue = new Queue(queueName, true);
        areaRabbitAdmin.declareQueue(queue);
        // 队列绑定交换机
        Binding binding = BindingBuilder.bind(queue).to(customExchange).with(queueName).noargs();
        areaRabbitAdmin.declareBinding(binding);

        // 发送消息
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("消息发送时间:"+sdf.format(new Date()));
        areaRabbitTemplate.convertAndSend("delayExchange", queueName, msg, new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message message) throws AmqpException {
                System.out.println("延时"+ttl+"秒=>"+(ttl*1000));
                //message.getMessageProperties().setDelay(ttl*1000);
//                message.getMessageProperties().setExpiration(String.valueOf(ttl*1000));
                //message.getMessageProperties().setExpiration("10000");
                //message.getMessageProperties().setHeader("x-delay",String.valueOf(ttl*1000));
//                message.getMessageProperties().setHeader("x-delay",ttl*1000);
                if (ttl*1000 > 4294967290L){
                    message.getMessageProperties().setHeader("x-delay","4294967290");
                } else {
                    message.getMessageProperties().setHeader("x-delay",String.valueOf(ttl*1000));
                }

//                message.getMessageProperties().setHeader("x-delay", 3000); //延迟9秒
//                message.getMessageProperties().setExpiration("32708637000");
                return message;

            }
        });
    }