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 2019/12/24 14:29:59 UTC
[camel-kafka-connector] branch master updated (14d9549 -> abdc9de)
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 14d9549 Merge pull request #56 from orpiske/retain-containers-after-build
add f8dc8db Convert the embeddable Kafka Connect runner to a JUnit rule
add abdc9de Convert the embeddable Kafka Connect runner to a JUnit rule (#57)
No new revisions were added by this update.
Summary of changes:
.../camel/kafkaconnector/AbstractKafkaTest.java | 11 +-
.../apache/camel/kafkaconnector/ContainerUtil.java | 57 ---------
.../apache/camel/kafkaconnector/TestCommon.java | 15 +--
.../kafkaconnector/clients/jms/JMSClient.java | 24 ++++
.../services/kafka/ContainerLocalKafkaService.java | 1 -
.../services/kafka/KafkaService.java | 4 -
.../DefaultKafkaConnectPropertyFactory.java | 6 +-
.../kafkaconnect}/KafkaConnectPropertyFactory.java | 2 +-
.../kafkaconnect}/KafkaConnectRunner.java | 114 +++++++++---------
.../kafkaconnect/KafkaConnectRunnerService.java | 132 +++++++++++++++++++++
.../kafkaconnect/KafkaConnectService.java} | 20 ++--
.../sink/aws/sns/CamelSinkAWSSNSITCase.java | 40 +++----
.../sink/aws/sqs/CamelAWSSQSPropertyFactory.java | 2 +-
.../sink/aws/sqs/CamelSinkAWSSQSITCase.java | 33 ++----
.../CamelSinkElasticSearchITCase.java | 26 ++--
.../sink/file/CamelSinkFileITCase.java | 25 ++--
.../sink/http/CamelSinkHTTPITCase.java | 18 +--
.../sink/jms/CamelSinkJMSITCase.java | 26 ++--
.../aws/kinesis/CamelSourceAWSKinesisITCase.java | 107 +++++++++--------
.../source/aws/s3/CamelSourceAWSS3ITCase.java | 28 ++---
.../source/aws/sqs/CamelSourceAWSSQSITCase.java | 30 ++---
.../source/jms/CamelSourceJMSITCase.java | 54 ++++++---
.../source/timer/CamelSourceTimerITCase.java | 18 +--
23 files changed, 414 insertions(+), 379 deletions(-)
rename tests/src/test/java/org/apache/camel/kafkaconnector/{ => services/kafkaconnect}/DefaultKafkaConnectPropertyFactory.java (90%)
copy tests/src/test/java/org/apache/camel/kafkaconnector/{ => services/kafkaconnect}/KafkaConnectPropertyFactory.java (95%)
rename tests/src/test/java/org/apache/camel/kafkaconnector/{ => services/kafkaconnect}/KafkaConnectRunner.java (73%)
create mode 100644 tests/src/test/java/org/apache/camel/kafkaconnector/services/kafkaconnect/KafkaConnectRunnerService.java
rename tests/src/test/java/org/apache/camel/kafkaconnector/{KafkaConnectPropertyFactory.java => services/kafkaconnect/KafkaConnectService.java} (61%)