Spring集成SQS-异常重试不起作用

Question

我正在致力于将Spring集成与AWS SQS队列集成。

当我用ServiceActivator注释的方法引发异常时，我遇到了一个问题。在这种情况下，消息似乎无论如何都会从队列中删除。我已在SqsMessageDrivenChannelAdapter中将MessageDeletionPolicy配置为成功时的。

这是我的通道/适配器配置https://github.com/sdusza1/spring-integration-sqs/blob/master/src/main/java/com/example/demo/ChannelConfig.java

我也尝试过使用SqsListener注释进行同样的操作，消息并没有按预期删除。

我在这里创建了一个迷你Spring Boot应用程序来演示此问题：https://github.com/sdusza1/spring-integration-sqs

请帮忙：）

Answer 1

您的配置如下：

@Bean
public MessageProducerSupport sqsMessageDrivenChannelAdapter() {
    SqsMessageDrivenChannelAdapter adapter = new SqsMessageDrivenChannelAdapter(amazonSqs, SQS_QUEUE_NAME);
    adapter.setOutputChannel(inboundChannel());
    adapter.setMessageDeletionPolicy(SqsMessageDeletionPolicy.ON_SUCCESS);
    adapter.setVisibilityTimeout(RETRY_NOTIFICATION_AFTER);
    return adapter;

}

其中in边界通道是这样的：

 @Bean
    public QueueChannel inboundChannel() {
        return new QueueChannel();
 }

因此，这是一个队列，因此是异步的，来自该队列的消息由TaskScheduler在单独的线程上处理，TaskScheduler根据您的PollerMetadata配置轮询此类通道。在这种情况下，使用者中的任何错误也会被抛出到该线程中，并且不会到达SqsMessageDrivenChannelAdapter进行预期的错误处理。

从技术上讲，这与您的SqsListener体验完全不同，后者实际上是直接在容器线程上调用的，因此应用了它的错误处理。

或者，您需要修改您希望如何处理该单独线程中的错误的逻辑，或者只是不在SqsMessageDrivenChannelAdapter之后使用队列通道，让它在底层SQS侦听器容器中抛出和处理错误，就像在SqsListener中一样。