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

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 6a7432a44e2758fb100b8b5e17e5ca6d784dcfe8
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Mar 1 09:43:15 2019 +0100

    Camel-AWS MSK: Fixed javadoc
---
 .../main/java/org/apache/camel/component/aws/msk/MSKComponent.java  | 6 +++---
 .../java/org/apache/camel/component/aws/msk/MSKConfiguration.java   | 6 +++---
 .../org/apache/camel/component/aws/msk/MSKProducerSpringTest.java   | 2 +-
 .../java/org/apache/camel/component/aws/msk/MSKProducerTest.java    | 2 +-
 4 files changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/components/camel-aws-msk/src/main/java/org/apache/camel/component/aws/msk/MSKComponent.java
 
b/components/camel-aws-msk/src/main/java/org/apache/camel/component/aws/msk/MSKComponent.java
index 5b6086a..c1d8210 100644
--- 
a/components/camel-aws-msk/src/main/java/org/apache/camel/component/aws/msk/MSKComponent.java
+++ 
b/components/camel-aws-msk/src/main/java/org/apache/camel/component/aws/msk/MSKComponent.java
@@ -27,7 +27,7 @@ import org.apache.camel.support.DefaultComponent;
 import org.apache.camel.util.ObjectHelper;
 
 /**
- * For working with Amazon KMS.
+ * For working with Amazon MSK.
  */
 @Component("aws-msk")
 public class MSKComponent extends DefaultComponent {
@@ -79,7 +79,7 @@ public class MSKComponent extends DefaultComponent {
     }
 
     /**
-     * The AWS KMS default configuration
+     * The AWS MSK default configuration
      */
     public void setConfiguration(MSKConfiguration configuration) {
         this.configuration = configuration;
@@ -112,7 +112,7 @@ public class MSKComponent extends DefaultComponent {
     }
 
     /**
-     * The region in which KMS client needs to work
+     * The region in which MSK client needs to work
      */
     public void setRegion(String region) {
         configuration.setRegion(region);
diff --git 
a/components/camel-aws-msk/src/main/java/org/apache/camel/component/aws/msk/MSKConfiguration.java
 
b/components/camel-aws-msk/src/main/java/org/apache/camel/component/aws/msk/MSKConfiguration.java
index aa7a3ff..7c2234c 100644
--- 
a/components/camel-aws-msk/src/main/java/org/apache/camel/component/aws/msk/MSKConfiguration.java
+++ 
b/components/camel-aws-msk/src/main/java/org/apache/camel/component/aws/msk/MSKConfiguration.java
@@ -95,7 +95,7 @@ public class MSKConfiguration implements Cloneable {
     }
 
     /**
-     * To define a proxy host when instantiating the KMS client
+     * To define a proxy host when instantiating the MSK client
      */
     public void setProxyHost(String proxyHost) {
         this.proxyHost = proxyHost;
@@ -106,7 +106,7 @@ public class MSKConfiguration implements Cloneable {
     }
 
     /**
-     * To define a proxy port when instantiating the KMS client
+     * To define a proxy port when instantiating the MSK client
      */
     public void setProxyPort(Integer proxyPort) {
         this.proxyPort = proxyPort;
@@ -117,7 +117,7 @@ public class MSKConfiguration implements Cloneable {
     }
 
     /**
-     * The region in which KMS client needs to work
+     * The region in which MSK client needs to work
      */
     public void setRegion(String region) {
         this.region = region;
diff --git 
a/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerSpringTest.java
 
b/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerSpringTest.java
index 861e888..3c46eda 100644
--- 
a/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerSpringTest.java
+++ 
b/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerSpringTest.java
@@ -36,7 +36,7 @@ public class MSKProducerSpringTest extends 
CamelSpringTestSupport {
     private MockEndpoint mock;
 
     @Test
-    public void kmsListKeysTest() throws Exception {
+    public void mskListKeysTest() throws Exception {
 
         mock.expectedMessageCount(1);
         Exchange exchange = template.request("direct:listClusters", new 
Processor() {
diff --git 
a/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerTest.java
 
b/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerTest.java
index 84a5854..c361f38 100644
--- 
a/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerTest.java
+++ 
b/components/camel-aws-msk/src/test/java/org/apache/camel/component/aws/msk/MSKProducerTest.java
@@ -37,7 +37,7 @@ public class MSKProducerTest extends CamelTestSupport {
     private MockEndpoint mock;
 
     @Test
-    public void kmsListClustersTest() throws Exception {
+    public void mskListClustersTest() throws Exception {
 
         mock.expectedMessageCount(1);
         Exchange exchange = template.request("direct:listClusters", new 
Processor() {

Reply via email to