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 ad8d0a9 SJMS2 itests: Avoid creating a new consumer for every message received new aaf1946 Make the AWS v2 sink test support reusable new c0e8ec1 Convert the AWS v1 tests to the new reusable sink test base class new e84c8c9 Convert the Azure storage blob tests to the new reusable sink test base class new 995b807 Convert the Azure storage queue tests to the new reusable sink test base class new b9b2fa0 Convert the Cassandra tests to the new reusable sink test base class new 51e7446 Convert the Couchbase tests to the new reusable sink test base class new 34dec6e Convert the ElasticSearch tests to the new reusable sink test base class new 6cdd1de Convert the File tests to the new reusable sink test base class new 2331048 Convert the HDFS tests to the new reusable sink test base class new 4f155bc Convert the HTTP tests to the new reusable sink test base class new 114dfe5 Convert the JDBC tests to the new reusable sink test base class new 66ef021 Convert the MongoDB tests to the new reusable sink test base class new 16063c8 Convert the RabbitMQ tests to the new reusable sink test base class new 525def9 Removed unused variables from SJMS2 DQL sink test new f2dc1aa Convert the SJMS2 tests to the new reusable sink test base class new fd4565b Convert the SQL tests to the new reusable sink test base class new f3cd060 Convert the SSH tests to the new reusable sink test base class new ad4a4f8 Convert the Syslog tests to the new reusable sink test base class new b7c040b Fix error message check for SJMS2 startup on error test new 61fab49 Temporarily disabled a error handling test for SJMS2 due to failures on GH actions new 8db432a Disabled MongoDB source test case due to GH issue #974 new a0a30e7 Disabled Azure storage queue tests due to GH issue #976 The 22 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/v1/sns/sink/CamelSinkAWSSNSITCase.java | 131 +++++++---------- .../aws/v1/sqs/sink/CamelSinkAWSSQSITCase.java | 130 +++++++---------- .../aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 4 +- .../aws/v2/ec2/sink/CamelSinkAWSEC2ITCase.java | 4 +- .../aws/v2/iam/sink/CamelSinkAWSIAMITCase.java | 4 +- .../v2/kinesis/sink/CamelSinkAWSKinesisITCase.java | 4 +- .../aws/v2/kms/sink/CamelSinkAWSKMSITCase.java | 4 +- .../aws/v2/s3/sink/CamelSinkAWSS3ITCase.java | 4 +- .../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 4 +- .../blob/sink/CamelSinkAzureStorageBlobITCase.java | 98 +++++++------ .../sink/CamelSinkAzureStorageQueueITCase.java | 82 +++++------ .../source/CamelSourceAzureStorageQueueITCase.java | 2 + .../cassandra/sink/CamelSinkCassandraITCase.java | 83 +++++------ .../kafkaconnector/common/AbstractKafkaTest.java | 5 + .../common/test/CamelSinkTestSupport.java} | 41 +++++- .../common/test/TestMessageProducer.java} | 9 +- .../couchbase/sink/CamelSinkCouchbaseITCase.java | 100 ++++++------- .../sink/CamelSinkElasticSearchITCase.java | 159 ++++++++------------- .../file/sink/CamelSinkFileITCase.java | 122 ++++++++-------- .../hdfs/sink/CamelSinkHDFSITCase.java | 95 ++++++------ .../http/sink/CamelSinkHTTPITCase.java | 106 +++++++------- .../jdbc/sink/CamelSinkJDBCITCase.java | 121 ++++++++-------- .../mongodb/sink/CamelSinkMongoDBITCase.java | 76 +++++----- .../mongodb/source/CamelSourceMongoDBITCase.java | 2 + .../rabbitmq/sink/RabbitMQSinkITCase.java | 120 ++++++++-------- .../sjms2/sink/CamelSinkIdempotentJMSITCase.java | 73 ++++------ .../sjms2/sink/CamelSinkJMSITCase.java | 118 ++++++--------- .../sjms2/sink/CamelSinkJMSStartupITCase.java | 6 +- .../sjms2/sink/CamelSinkWithDLQJMSITCase.java | 2 - .../sql/sink/CamelSinkSQLITCase.java | 118 +++++++-------- .../ssh/sink/CamelSinkSshITCase.java | 67 +++++---- .../syslog/sink/CamelSinkSyslogITCase.java | 71 ++++----- 32 files changed, 919 insertions(+), 1046 deletions(-) rename tests/{itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java => itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSinkTestSupport.java} (67%) copy tests/{itests-jdbc/src/test/resources/schema.sql => itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/TestMessageProducer.java} (84%)