Используйте Spring Integration DSL для чтения из раздела Tibco EMS

Я пытался настроить весеннюю интеграцию dsl для чтения из темы Tibco EMS, выполнить некоторую обработку полученного сообщения, а затем отправить его в очередь ActiveMQ. Мне удалось успешно настроить это с помощью конфигурации XML, но вместо этого я хотел использовать Spring Integration dsl. Я не мог понять, и не мог найти никакой помощи в Интернете по этому поводу.

Моя конфигурация для отправки сообщения в ActiveMQ примерно такая:

@Bean
public IntegrationFlow toActiveMQFlow(
        MessageChannel channel,
        ActiveMQQueue queue,
        CachingConnectionFactory cachingConnectionFactory) {
    return IntegrationFlows.from(channel)
            .transform(Object::toString)
            .handle(Jms.outboundAdapter(cachingConnectionFactory).destination(queue))
            .get();
}

И я думаю, что конфигурация для чтения из тем Tibco EMS должна быть примерно такой -

@Bean
public IntegrationFlow fromTibcoTopicFlow(
        MessageChannel channel,
        ConnectionFactory tibcoEmsConnectionFactory,
        Topic tibcoTopic
) {
    return IntegrationFlows
            .from(SomeInboundAdapter(tibcoEmsConnectionFactory).destination(tibcoTopic))
            .transform(Object::toString)
            .channel(channel)
            .get();
}

Поскольку я не нашел особой помощи по последней конфигурации, является ли здесь единственным вариантом использования конфигурации XML?

Пожалуйста, исправьте / отредактируйте / укажите на любые ошибки, которые я допустил, все еще изучая Spring Integration DSL.

Ценю вашу помощь!