Spring起動にRedeliveryPolicyを注入するActiveMQ

Question

私はspring-boot-starter-activemqをPoolFactoryと使用しています。すべてうまく動作し、application.yamlで設定するのは簡単ですが、私は自分のカスタムRedeliveryPolicyを注入する正しい方法を見つけることができません。それではどうしたらいいですか？

Answer 1

再配信ポリシーは、接続ファクトリで設定できます。接続ファクトリはスプリングブートによって自動的に設定されるため、設定する方法を追加できます。

import org.apache.activemq.ActiveMQConnectionFactory; 
import org.apache.activemq.RedeliveryPolicy; 
import org.springframework.beans.factory.InitializingBean; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 

@Configuration 
public class Foo 
{ 
    @Bean 
    public InitializingBean connectionFactory(ActiveMQConnectionFactory connectionFactory) 
    { 
     return() -> 
     { 
      RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy(); 
      // configure redelivery policy 
      connectionFactory.setRedeliveryPolicy(redeliveryPolicy); 
     }; 
    } 
}