如何使用RabbitTemplate设置每条消息的TTL？

Question

我使用rabbitMQ的spring-boot，我想知道是否可以使用RabbitTemplate的每条消息TTL。到目前为止，我有：

@Autowired 
    private RabbitTemplate rabbit; 

    public void produce() { 

     rabbit.convertAndSend("My.Queue", routingKey, message); 
    } 

Answer 1

您可以创建MessagePostProcessor和你rabbitTemplate使用它：

final String message = "message"; 
final MessagePostProcessor messagePostProcessor = new MyMessagePostProcessor(10000); 
rabbitTemplate.convertAndSend("my.queue", "routingKey", message, messagePostProcessor); 

这会抓住你的消息，应用更改并进一步发送。

public class MyMessagePostProcessor implements MessagePostProcessor { 

    private final Integer ttl; 

    public MyMessagePostProcessor(final Integer ttl) { 
     this.ttl = ttl; 
    } 

    @Override 
    public Message postProcessMessage(final Message message) throws AmqpException { 
     message.getMessageProperties().getHeaders().put("expiration", ttl.toString()); 
     return message; 
    } 
} 

Answer 2

只是有一点点的解决方法：

@Autowired 
    private RabbitTemplate rabbit; 

    @Autowired 
    private MessageConverter jsonMessageConverter; 

    public void produce() { 

     rabbit.setExchange("My.Exchange"); 
     rabbit.setRoutingKey("R.K"); 
     rabbit.setMessageConverter(jsonMessageConverter); 
     MessageProperties props = new MessageProperties(); 
     props.setExpiration(Long.toString(expiration)); 
     Message toSend = new Message(message.toString().getBytes(), props); 
     rabbit.send(toSend); 
    }