This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 084c8f0 Added missing slow tests filter to avoid trying to run the
AWS v2 test on GH actions
new cdbeea8 Added a reusable base class for the source tests
new 293ed7d Converted AWS source tests to use the reusable source base
class
new fdeee2a Converted the Azure storage queue source test case to use the
reusable source base class
new ac80745 Converted the Cassandra source test case to use the reusable
source base class
new d6f900d Converted the MongoDB source test case to use the reusable
source base class
new fd96d0f Converted the RabbitMQ source test case to use the reusable
source base class
new 6145ff4 Converted the SJMS2 source test cases to use the reusable
source base class
new d1f8099 Converted the SQL source test case to use the reusable source
base class
new dafface Converted the SSH source test case to use the reusable source
base class
new 85b9701 Converted the Syslog source test case to use the reusable
source base class
new 99cebce Converted the Timer source test case to use the reusable
source base class
The 11 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../source/CamelSourceAWSKinesisITCase.java | 54 ++-----
.../kafkaconnector/aws/v2/s3/common/S3Utils.java | 32 ++++
.../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 164 +++++----------------
.../CamelSourceAWSS3LargeFilesITCase.java} | 135 ++++++++---------
.../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 51 +++----
.../source/CamelSourceAzureStorageQueueITCase.java | 57 +++----
.../source/CamelSourceCassandraITCase.java | 60 +++-----
...ducer.java => AbstractTestMessageConsumer.java} | 55 ++++---
.../common/test/CamelSourceTestSupport.java | 126 ++++++++++++++++
...geProducer.java => IntegerMessageConsumer.java} | 13 +-
...ageProducer.java => StringMessageConsumer.java} | 13 +-
...ssageProducer.java => TestMessageConsumer.java} | 10 +-
.../mongodb/source/CamelSourceMongoDBITCase.java | 49 +++---
.../rabbitmq/source/RabbitMQSourceITCase.java | 64 ++++----
.../sjms2/source/CamelSourceJMSITCase.java | 127 ++++++----------
.../source/CamelSourceJMSWithAggregation.java | 110 ++++++++------
.../sql/source/CamelSourceSQLITCase.java | 47 +++---
.../ssh/sink/CamelSinkSshITCase.java | 3 +-
.../ssh/source/CamelSourceSshITCase.java | 47 ++----
.../syslog/source/CamelSourceSyslogITCase.java | 124 ++++++++--------
.../timer/source/CamelSourceTimerITCase.java | 53 +++----
21 files changed, 645 insertions(+), 749 deletions(-)
copy
tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/{sink/CamelSinkAWSS3ITCase.java
=> source/CamelSourceAWSS3LargeFilesITCase.java} (52%)
copy
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/{AbstractTestMessageProducer.java
=> AbstractTestMessageConsumer.java} (54%)
create mode 100644
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java
copy
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/{TestMessageProducer.java
=> IntegerMessageConsumer.java} (68%)
copy
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/{TestMessageProducer.java
=> StringMessageConsumer.java} (68%)
copy
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/{FunctionalTestMessageProducer.java
=> TestMessageConsumer.java} (80%)
