Spring boot RabbitMq 延迟消息

spring:
  redis:
    host: 127.0.0.1
    port: 6377
  rabbitmq:
    host: localhost
    virtual-host: /
    port: 5672
    password: 123456
    username: yuanbin

public static final String DELAY_EXCHANGE_NAME = "delayed_exchange";
public static final String DELAY_QUEUE_NAME = "delay_queue_name";
public static final String DELAY_ROUTING_KEY = "delay_routing_key";

@Bean
public CustomExchange delayExchange()
{
    Map<String, Object> args = new HashMap<>();
    args.put("x-delayed-type", "direct");
    return new CustomExchange(DELAY_EXCHANGE_NAME, "x-delayed-message", true, false, args);
}

@Bean
public Queue queue()
{
    Queue queue = new Queue(DELAY_QUEUE_NAME, true);
    return queue;
}

@Bean
public Binding binding(Queue queue, CustomExchange delayExchange)
{
    return BindingBuilder.bind(queue).to(delayExchange).with(DELAY_ROUTING_KEY).noargs();
}

@GetMapping("/sendDelayMessage")
public String sendDelayMessage() {
    String messageId = String.valueOf(UUID.randomUUID());
    String messageData = "test message, hello!";
    String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
    Map<String,Object> map=new HashMap<>();
    map.put("messageId",messageId);
    map.put("messageData",messageData);
    map.put("createTime",createTime);
    System.out.println("DirectReceiver生产者发送消息  : " + createTime);
    //将消息携带绑定键值：DirectRabbitConfig.DELAY_ROUTING_KEY发送到交换机DirectRabbitConfig.DELAY_EXCHANGE_NAME
    rabbitTemplate.convertAndSend(DirectRabbitConfig.DELAY_EXCHANGE_NAME, DirectRabbitConfig.DELAY_ROUTING_KEY, map, new MessagePostProcessor(){
        @Override
        public Message postProcessMessage(Message message) throws AmqpException {
            //给消息加上header,表明是一个延迟消息，并且设置过期时间3秒
            message.getMessageProperties().setHeader("x-delay",3000);
            return message;
        }
    });
    return "ok";
}

@RabbitListener(queues = DirectRabbitConfig.DELAY_QUEUE_NAME )
@RabbitHandler
//message就是传过来的参数值
public void processMeatTwo(Map<String,Object> message) {
    System.out.println("processMeatTwo消费了队列meat_queue的消息:" + message);
}