Подпоток Spring Integration в зависимости от метода .handle

Я использую интеграцию spring для изменения потока после завершения конкретной попытки. Мой bean-компонент IntegrationFlow для errorResponse выглядит следующим образом:

@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-подпотоки

@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();
}

Любая помощь приветствуется.