This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 00d7241 Added camel-paho-mqtt5 to generated connectors json
new b276cf2 Added missing slow tests filter to avoid trying to run the
AWS v2 test on GH actions
new fc34cba Added a reusable base class for the source tests
new 0a74584 Converted AWS source tests to use the reusable source base
class
new 0fa2149 Converted the Azure storage queue source test case to use the
reusable source base class
new fe801e0 Converted the Cassandra source test case to use the reusable
source base class
new e6e7f97 Converted the MongoDB source test case to use the reusable
source base class
new b55096e Converted the RabbitMQ source test case to use the reusable
source base class
new e95b9fb Converted the SJMS2 source test cases to use the reusable
source base class
new f2f51b1 Converted the SQL source test case to use the reusable source
base class
new 550d1a2 Converted the SSH source test case to use the reusable source
base class
new de00cf1 Converted the Syslog source test case to use the reusable
source base class
new ba38537 Converted the Timer source test case to use the reusable
source base class
new 2d018cb Disabled Azure storage blob tests due to GH issue #997
new bc99e54 Disabled Azure storage queue sink tests due to GH issue #976
The 14 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:
.../aws/v2/ec2/sink/CamelSinkAWSEC2ITCase.java | 2 +
.../aws/v2/iam/sink/CamelSinkAWSIAMITCase.java | 2 +
.../v2/kinesis/sink/CamelSinkAWSKinesisITCase.java | 1 -
.../source/CamelSourceAWSKinesisITCase.java | 54 ++-----
.../kafkaconnector/aws/v2/s3/common/S3Utils.java | 32 ++++
.../aws/v2/s3/sink/CamelSinkAWSS3ITCase.java | 2 +
.../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 164 +++++----------------
.../CamelSourceAWSS3LargeFilesITCase.java} | 135 ++++++++---------
.../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 51 +++----
.../blob/sink/CamelSinkAzureStorageBlobITCase.java | 2 +
.../sink/CamelSinkAzureStorageQueueITCase.java | 2 +
.../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 +++----
27 files changed, 656 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%)
