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 <anco...@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");