Я вижу много примеров, связанных с файлом интеграции Spring. Но я ищу пример приложения, в котором он использует spring-integration-jpa для извлечения данных из базы данных с помощью адаптера входящего канала и создания из него объекта Java.
Любая помощь горячо приветствуется.
В официальном репозитории 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();
}
