Пример для Spring Integration с spring-интеграцией-jpa

Question

Я вижу много примеров, связанных с spring -gration-file. Но я ищу пример приложения, в котором оно использует spring -gration-jpa для извлечения данных из базы данных с помощью адаптера входящего канала и создания из него объекта Java.

Любая помощь очень ценится.

Answer 1

В официальном репозитории Spring Integration Samples есть базовый образец JPA: https://github.com/spring-projects/spring-integration-samples/tree/master/basic/jpa.

Простой пример Java DSL для адаптера входящего канала может выглядеть следующим образом:

    @Bean
    public IntegrationFlow pollingAdapterFlow(EntityManagerFactory entityManagerFactory) {
        return IntegrationFlows
                .from(Jpa.inboundAdapter(entityManagerFactory)
                                .entityClass(StudentDomain.class)
                                .maxResults(1)
                                .expectSingleResult(true),
                        e -> e.poller(p -> p.trigger(new OnlyOnceTrigger())))
                .channel(c -> c.queue("pollingResults"))
                .get();
    }