Spring AMQPを使用してリスナーに送信する遅延メッセージ

Question

私は、一定期間の後にMessageListenerにメッセージを送信する必要があります。したがって、Spring AMQPを使用して達成する方法はありますか。

例： プロデューサーがメッセージを生成し、メッセージがRabbitMQに送られます。Qメッセージが受信されます。リスナーは、すぐにそのQを聞いて、何らかの設定パラメータの後に消費者側で受け取るメッセージを遅らせたいとします。

Answer 1

RabbitMQはこの目的のDelayed Exchange機能です。 http://docs.spring.io/spring-amqp/reference/html/_reference.html#delayed-message-exchange：あなたが好きすべき春AMQP 1.6前

<rabbit:topic-exchange name="topic" delayed="true" /> 

---

MessageProperties properties = new MessageProperties(); 
properties.setDelay(15000); 
template.send(exchange, routingKey, 
     MessageBuilder.withBody("foo".getBytes()).andProperties(properties).build()); 

UPDATE

をバージョン1.6春AMQPも問題にハイレベルのAPIを提供して以降では

これは：

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

... 

MessageProperties properties = new MessageProperties(); 
properties.setHeader("x-delay", 15000); 
template.send(exchange, routingKey, 
     MessageBuilder.withBody("foo".getBytes()).andProperties(properties).build()); 

この質問とその回答もご覧ください：Scheduled/Delay messaging in Spring AMQP RabbitMq