import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessagePostProcessor;

@Test
public void testSendMessageTTL() {

    // 1、创建消息后置处理器对象
    MessagePostProcessor messagePostProcessor = (Message message) -> {

        // 设定 TTL 时间，以毫秒为单位
        message.getMessageProperties().setExpiration("5000");

        return message;
    };

    // 2、发送消息
    rabbitTemplate.convertAndSend(
            EXCHANGE_DIRECT,
            ROUTING_KEY,
            "Hello atguigu", messagePostProcessor);
}