[Improve][Connector-V2] Change amazonsqs to AmazonSqs as connecto…

…r identifier (#5742)
apache · Oct 30, 2023 · 245705d · 245705d
1 parent 7f3b4be
commit 245705d
Show file tree

Hide file tree

Showing 6 changed files with 13 additions and 6 deletions.
diff --git a/docs/en/connector-v2/sink/AmazonSqs.md b/docs/en/connector-v2/sink/AmazonSqs.md
@@ -75,7 +75,7 @@ source {
 }
 
 sink {
-  amazonsqs {
+  AmazonSqs {
     url = "http://127.0.0.1:8000"
     region = "us-east-1"
     queue = "queueName"

diff --git a/docs/en/connector-v2/source/AmazonSqs.md b/docs/en/connector-v2/source/AmazonSqs.md
@@ -37,7 +37,7 @@ Read data from Amazon SQS.
 
 ```bash
 source {
-  amazonsqs {
+  AmazonSqs {
     url = "http://127.0.0.1:4566"
     region = "us-east-1"
     format = text

diff --git a/...src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSink.java b/...src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSink.java
@@ -50,7 +50,7 @@ public class AmazonSqsSink extends AbstractSimpleSink<SeaTunnelRow, Void> {
 
     @Override
     public String getPluginName() {
-        return "amazonsqs";
+        return "AmazonSqs";
     }
 
     public AmazonSqsSink(ReadonlyConfig pluginConfig, SeaTunnelRowType typeInfo) {

diff --git a/...main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/source/AmazonSqsSource.java b/...main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/source/AmazonSqsSource.java
@@ -69,7 +69,7 @@ public class AmazonSqsSource extends AbstractSingleSplitSource<SeaTunnelRow>
 
     @Override
     public String getPluginName() {
-        return "amazonsqs";
+        return "AmazonSqs";
     }
 
     @Override

diff --git a/seatunnel-dist/pom.xml b/seatunnel-dist/pom.xml
@@ -521,6 +521,13 @@
                     <scope>provided</scope>
                 </dependency>
 
+                <dependency>
+                    <groupId>org.apache.seatunnel</groupId>
+                    <artifactId>connector-amazonsqs</artifactId>
+                    <version>${project.version}</version>
+                    <scope>provided</scope>
+                </dependency>
+
                 <!-- jdbc driver -->
                 <dependency>
                     <groupId>com.aliyun.phoenix</groupId>

diff --git a/...nnector-v2-e2e/connector-amazonsqs-e2e/src/test/resources/amazonsqsIT_source_to_sink.conf b/...nnector-v2-e2e/connector-amazonsqs-e2e/src/test/resources/amazonsqsIT_source_to_sink.conf
@@ -26,7 +26,7 @@ env {
 
 source {
   # This is a example source plugin **only for test and demonstrate the feature source plugin**
-  amazonsqs {
+  AmazonSqs {
     url = "http://sqs-host:4566/000000000000/source_queue"
     access_key_id = "1234"
     secret_access_key = "abcd"
@@ -46,7 +46,7 @@ transform {
 
 sink {
  # This is a example source plugin **only for test and demonstrate the feature sink plugin**
-   amazonsqs {
+  AmazonSqs {
      url = "http://sqs-host:4566/000000000000/sink_queue"
      access_key_id = "1234"
      secret_access_key = "abcd"