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() {