Spring統合電子メール再配信例外の場合

Question

GET Httpメソッドを使用して、ユーザーがpersonオブジェクトを要求するWebサービスがあります。この人はJMSキューに送られ、Spring Integrationの助けを借りて私は偽の電子メールアドレス（https://papercut.codeplex.com/）に送ります。私はSpring Integration Java DSLでコードを書いています。

1. メールメッセージをもっと柔軟に送信する方法はありますか？

2. 例外がスローされた場合、Spring Integrationの助けを借りてどのようにメールを再配信できますか？

    public Person findById(Integer id) { 
        Person person = jpaPersonRepository.findOne(id); 
        jmsTemplate.convertAndSend("testQueue", person); 
        return jpaPersonRepository.findOne(id); 
       } 
   

   のJava Confiuration

Webサービス： はここに私のコードです（5回例えば、それは、次に送信されない場合は、例外が処理されますと、プログラムが停止します）

@Configuration @EnableIntegration @ComponentScan public class JavaConfig { private static final String DEFAULT_BROKER_URL = "tcp://localhost:61616"; private static final String DEFAULT_QUEUE = "testQueue"; @Bean public ActiveMQConnectionFactory connectionFactory() { ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); connectionFactory.setBrokerURL(DEFAULT_BROKER_URL); return connectionFactory; } @Bean public JmsTemplate jmsTemplate() { JmsTemplate template = new JmsTemplate(); template.setConnectionFactory(this.connectionFactory()); template.setDefaultDestinationName(DEFAULT_QUEUE); return template; } @Bean public DefaultMessageListenerContainer defaultMessageListenerContainer() { DefaultMessageListenerContainer defaultMessageListenerContainer = new DefaultMessageListenerContainer(); defaultMessageListenerContainer.setDestinationName(DEFAULT_QUEUE); defaultMessageListenerContainer.setConnectionFactory(this.connectionFactory()); return defaultMessageListenerContainer; } @Bean(name="inputChannel") public DirectChannel directChannel() { return new DirectChannel(); } @Bean public IntegrationFlow orders() { return IntegrationFlows .from(Jms.messageDrivenChannelAdapter(defaultMessageListenerContainer())) .transform(new ObjectToStringTransformer()) .enrichHeaders(p -> p.header(MailHeaders.TO, "Papercut0@test.com")) .handle(Mail.outboundAdapter("127.0.0.1") .credentials("test","test").port(25) .javaMailProperties(p -> p.put("mail.debug", "true")), e -> e.id("sendMailEndpoint")) .get(); } } 

Answer 1

電子メールメッセージを送信するためのより柔軟な方法？

申し訳ありませんが、質問は不明です。それを行うのに十分な短いコードがあります。 Mail.outboundAdapter()とすべての流暢なAPI。より柔軟なものは何ですか？

例外がスローされた場合、Spring Integrationの助けを借りてどのようにメールを再配信できますか？

この目的のために、春の統合ではRequestHandlerRetryAdviceが推奨されます。

@Bean 
public Advice retryAdvice() { 
    RequestHandlerRetryAdvice advice = new RequestHandlerRetryAdvice(); 
    RetryTemplate retryTemplate = new RetryTemplate(); 
    SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(); 
    retryPolicy.setMaxAttempts(5); 
    retryTemplate.setRetryPolicy(retryPolicy); 
    advice.setRetryTemplate(retryTemplate); 
    advice.setRecoveryCallback(new ErrorMessageSendingRecoverer(emailErrorChannel())); 
    return advice; 
} 

... 

.handle(Mail.outboundAdapter("127.0.0.1") 
       .credentials("test","test").port(25) 
       .javaMailProperties(p -> p.put("mail.debug", "true")), 
       e -> e.id("sendMailEndpoint") 
         .advice(retryAdvice())) // HERE IS THE TRICK! 

そのJavadocを参照してください問題についてReference Manual：そしてMail.outboundAdapter()はそのように設定することができます。