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