You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by va...@apache.org on 2020/01/08 21:47:51 UTC

[camel-kafka-connector] 01/01: Add integration test for Cassandra CQL (#64)

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

valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit f1b3f8009684f93b4dac6d32978d04e393503495
Merge: e0ed770 0594848
Author: Andrea Tarocchi <an...@gmail.com>
AuthorDate: Wed Jan 8 22:47:39 2020 +0100

    Add integration test for Cassandra CQL (#64)
    
    Add integration test for Cassandra CQL

 .../apache/camel/kafkaconnector/TestCommon.java    |  58 ++++++++++
 .../clients/cassandra/CassandraClient.java         |  47 ++++++++
 .../clients/cassandra/dao/TestDataDao.java         | 116 ++++++++++++++++++++
 .../clients/elasticsearch/ElasticSearchClient.java |  47 +-------
 .../services/cassandra/CassandraService.java       |  49 +++++++++
 .../cassandra/CamelCassandraPropertyFactory.java   |  58 ++++++++++
 .../sink/cassandra/CamelSinkCassandraITCase.java   | 118 +++++++++++++++++++++
 7 files changed, 448 insertions(+), 45 deletions(-)