Spring Integration 子流程取决于 .handle 方法

Question

我正在使用 spring 集成在特定重试完成后更改流程。我的 errorResponse 的 IntegrationFlow bean 如下：

@Bean
public IntegrationFlow errorMailResponse(@Qualifier(ERROR_CHANNEL) PollableChannel errorChannel) {
    return IntegrationFlows.from(errorChannel)
            .handle(MessagingException.class, (payload, headers) -> handleMessageException(payload),
                    e -> e.poller(p -> p.fixedDelay(pollerInterval)))
            .channel(NO_OUTPUT_CHANNEL)
            .get();
}

如果方法 handleMessageException 返回一个对象，我希望流程继续到特定通道 - MAIN_EVENTS_CHANNEL 如果 handleMessageException 返回 null，我希望继续到 NO_OUTPUT_CHANNEL 。

通过 Spring 集成可以实现吗？我尝试使用子流，但我不确定这是否是这样。 https://docs.spring.io/ spring-integration/reference/html/dsl.html#java-dsl-subflows

@Bean
public IntegrationFlow errorMailResponse(@Qualifier(ERROR_CHANNEL) PollableChannel errorChannel) {
    return IntegrationFlows.from(errorChannel)
            .handle(MessagingException.class, (payload, headers) -> handleMailMessageException(payload),
                    e -> e.poller(p -> p.fixedDelay(pollerInterval)))
            .publishSubscribeChannel(subscription -> subscription
                    .subscribe(subflow -> subflow
                            .<MailPojo>handle((payload, headers) -> {
                                // if if result handleMessageException  == null
                            })
                            .channel(NO_OUTPUT_CHANNEL))
                    .subscribe(subflow -> subflow
                            .<MailPojo>handle((payload, headers) -> {
                               // if result handleMessageException  !=null
                            })
                            .channel(MAIN_EVENTS_CHANNEL)))
            .get();
}

感谢任何帮助。

Answer 1

首先，null 不是payload。因此，消息传递在大多数情况下不支持 null。集成流程仅在返回 null 时停止：https://docs.spring.io/spring-integration/docs/current/reference/html/messaging-endpoints.html#service-activator-namespace< /a>

服务激活器是不需要生成回复消息的组件之一。如果您的方法返回 null 或具有 void 返回类型，则服务激活器将在方法调用后退出，而不产生任何信号。

因此，您做出逻辑决定的假设对于 Spring Integration 来说是不正确的。您需要考虑什么可以用作此类 NO_OUTPUT_CHANNEL 的信号。您可以创建一个人工 NullType 并使用 PayloadTypeRouter 来根据 handleMailMessageException() 返回的有效负载类型确定下一步何时进行：

.<Object, Class<?>>route(Object::getClass, m -> m
                        .channelMapping(MailPojo.class, MAIN_EVENTS_CHANNEL)
                        .channelMapping(NullType.class, NO_OUTPUT_CHANNEL))

另一种方法就是使用一个Optional并在router函数中检查它的内容。无论哪种方式，您都需要使用路由器。