2016-07-05 6 views
1

これは私がそれならばメッセージも持続的にマークする必要があること、それが書かれているインターネット上の記事をたくさん読んだか私が交換を作成し、それspring-rabbitmqを使用して永続的なメッセージをマークする方法は?

<rabbit:topic-exchange id="dataExchange" name="MQ-EXCHANGE" durable="true"> 
     <rabbit:bindings> 
      <rabbit:binding queue="COMM_QUEUE" pattern="queue.*" /> 
     </rabbit:bindings> 
</rabbit:topic-exchange> 

にキューを結合していていますrabbitmqまたはキューがクラッシュした場合に保護されます。しかし、私はメッセージを永続的にする方法を理解できませんでした。

これは私がキュー

@Autowired 
    private RabbitTemplate template; 

    @Override 
    public void produceMessage(Object message, String routingKey) { 
     template.convertAndSend(routingKey, message); 
    } 

にメッセージを公開していますどのように私はこれを知っているさまざまなAPIメソッドのために見ても、私はXMLで設定することができ、特定のプロパティを探してみましたが、couldn方法を見つけません。どんな指導?

答えて

3

デフォルト配信モード(MessagePropertiesPERSISTENTです。 hereを参照してください。

非永続化するには、メソッドをMessagePostProcessorとし、deliveryModeプロパティを設定する必要があります。

+0

ソリューションのおかげで@Gary –

関連する問題