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 cae8d237728865746ae40da1acc2c5f581ca8f5c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 17 12:53:33 2020 +0100
Camel-AWS2-DDB: Cleanup
---
.../org/apache/camel/component/aws2/ddb/BatchGetItemsCommandTest.java | 3 ++-
.../camel/component/aws2/ddb/DdbComponentRegistryClientTest.java | 2 +-
.../component/aws2/ddb/integration/DdbComponentIntegrationTest.java | 2 +-
3 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/BatchGetItemsCommandTest.java b/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/BatchGetItemsCommandTest.java
index 3143725..5fc8755 100644
--- a/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/BatchGetItemsCommandTest.java
+++ b/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/BatchGetItemsCommandTest.java
@@ -45,7 +45,8 @@ public class BatchGetItemsCommandTest {
command = new BatchGetItemsCommand(ddbClient, configuration, exchange);
}
- @Test
+ @SuppressWarnings("unchecked")
+ @Test
public void execute() {
Map<String, AttributeValue> key = new HashMap<>();
key.put("1", AttributeValue.builder().s("Key_1").build());
diff --git a/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/DdbComponentRegistryClientTest.java b/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/DdbComponentRegistryClientTest.java
index d593e08..9210038 100644
--- a/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/DdbComponentRegistryClientTest.java
+++ b/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/DdbComponentRegistryClientTest.java
@@ -38,7 +38,7 @@ public class DdbComponentRegistryClientTest extends CamelTestSupport {
public void createEndpointWithoutRegistryClient() throws Exception {
Ddb2Component component = context.getComponent("aws2-ddb", Ddb2Component.class);
assertThrows(IllegalArgumentException.class, () -> {
- Ddb2Endpoint endpoint = (Ddb2Endpoint)component.createEndpoint("aws2-ddb://myTable");
+ component.createEndpoint("aws2-ddb://myTable");
});
}
}
diff --git a/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/integration/DdbComponentIntegrationTest.java b/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/integration/DdbComponentIntegrationTest.java
index a198e47..d6a7f93 100644
--- a/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/integration/DdbComponentIntegrationTest.java
+++ b/components/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/integration/DdbComponentIntegrationTest.java
@@ -122,7 +122,7 @@ public class DdbComponentIntegrationTest extends CamelTestSupport {
Map<String, AttributeValue> key = new HashMap<>();
key.put(attributeName, AttributeValue.builder().n(randomId).build());
- Exchange exchange = template.send("direct:start", new Processor() {
+ template.send("direct:start", new Processor() {
public void process(Exchange exchange) throws Exception {
exchange.getIn().setHeader(Ddb2Constants.KEY, key);
exchange.getIn().setHeader(Ddb2Constants.RETURN_VALUES, "ALL_OLD");