This is an automated email from the ASF dual-hosted git repository.

gnodet pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 42d6823faf9971aa2ae0e16873a03a7eced1d2cf
Merge: f8fe773a04f7 187301a246ad
Author: Guillaume Nodet <[email protected]>
AuthorDate: Wed Sep 2 17:19:11 2026 +0200

    Merge pull request #25993 from 
apache/implement-the-keyvaluerepository-implementations-f
    
    CAMEL-24463: Add KeyValueRepository implementations for JDBC, JPA, 
Cassandra, and Kafka

 .../org/apache/camel/catalog/beans.properties      |   4 +
 .../catalog/beans/CassandraKeyValueRepository.json |  16 +
 .../catalog/beans/JdbcKeyValueRepository.json      |  16 +
 .../camel/catalog/beans/JpaKeyValueRepository.json |  16 +
 .../catalog/beans/KafkaKeyValueRepository.json     |  16 +
 .../camel/catalog/docs/state-store-component.adoc  |  75 +--
 .../CassandraKeyValueRepositoryConfigurer.java     |  63 ++
 .../services/org/apache/camel/bean.properties      |   2 +-
 .../camel/bean/CassandraKeyValueRepository.json    |  16 +
 ....keyvalue.cassandra.CassandraKeyValueRepository |   2 +
 .../cassandra/CassandraKeyValueRepository.java     | 369 ++++++++++++
 .../cassandra/CassandraKeyValueRepositoryIT.java   | 244 ++++++++
 .../src/test/resources/initScript.cql              |   6 +
 components/camel-jpa/pom.xml                       |   2 +-
 .../jpa/JpaKeyValueRepositoryConfigurer.java       |  69 +++
 .../services/org/apache/camel/bean.properties      |   7 +
 .../apache/camel/bean/JpaKeyValueRepository.json   |  16 +
 ...el.processor.keyvalue.jpa.JpaKeyValueRepository |   2 +
 .../keyvalue/jpa/JpaKeyValueRepository.java        | 513 ++++++++++++++++
 .../processor/keyvalue/jpa/KeyValueEntry.java      | 108 ++++
 .../keyvalue/jpa/JpaKeyValueRepositoryTest.java    | 248 ++++++++
 .../src/test/resources/META-INF/persistence.xml    |  12 +
 .../kafka/KafkaKeyValueRepositoryConfigurer.java   |  90 +++
 .../services/org/apache/camel/bean.properties      |   2 +-
 .../apache/camel/bean/KafkaKeyValueRepository.json |  16 +
 ...rocessor.keyvalue.kafka.KafkaKeyValueRepository |   2 +
 .../keyvalue/kafka/KafkaKeyValueRepository.java    | 664 +++++++++++++++++++++
 .../keyvalue/kafka/KafkaKeyValueRepositoryIT.java  | 262 ++++++++
 .../jdbc/JdbcKeyValueRepositoryConfigurer.java     | 117 ++++
 .../services/org/apache/camel/bean.properties      |   2 +-
 .../apache/camel/bean/JdbcKeyValueRepository.json  |  16 +
 ....processor.keyvalue.jdbc.JdbcKeyValueRepository |   2 +
 .../keyvalue/jdbc/JdbcKeyValueRepository.java      | 448 ++++++++++++++
 .../keyvalue/jdbc/JdbcKeyValueRepositoryTest.java  | 253 ++++----
 .../src/main/docs/state-store-component.adoc       |  75 +--
 .../support/MemoryKeyValueRepositoryTest.java      | 107 ++--
 docs/user-manual/modules/ROOT/nav.adoc             |   1 +
 .../modules/ROOT/pages/key-value-repository.adoc   | 345 +++++++++++
 38 files changed, 3898 insertions(+), 326 deletions(-)

Reply via email to