You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/14 10:43:23 UTC

[camel-kafka-connector] 03/05: Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-sqs

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

acosentino pushed a commit to branch conv-aggr-transform-alignment
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 07c1230805fc579b822a781c556ae1e9c6e8fcef
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 11:45:42 2020 +0200

    Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-sqs
---
 .../{SQSKeySetterTransformers.java => SQSKeySetterTransforms.java}      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java
similarity index 95%
rename from connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java
rename to connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java
index 7da0da4..1a14c46 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java
@@ -24,7 +24,7 @@ import org.apache.kafka.connect.data.Schema;
 import org.apache.kafka.connect.header.Headers;
 import org.apache.kafka.connect.transforms.Transformation;
 
-public class SQSKeySetterTransformers<R extends ConnectRecord<R>> implements Transformation<R> {
+public class SQSKeySetterTransforms<R extends ConnectRecord<R>> implements Transformation<R> {
 
     public static final ConfigDef CONFIG_DEF = new ConfigDef()
             .define("test", ConfigDef.Type.STRING, "test", ConfigDef.Importance.MEDIUM, "Fetch the Camel.CamelAwsSqsMessageId header and set it as the key for the kafka record");