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 8e7100a032a487fe320bf7a2666bd9ab01ff06d7 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Tue Mar 17 17:49:12 2020 +0100 Camel-AWS2-MQ: Cleanup --- .../src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java | 3 ++- .../apache/camel/component/aws2/mq/MQComponentClientRegistryTest.java | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/components/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java b/components/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java index accadd9..0adb5c6 100644 --- a/components/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java +++ b/components/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Producer.java @@ -127,7 +127,8 @@ public class MQ2Producer extends DefaultProducer { message.setBody(result); } - private void createBroker(MqClient mqClient, Exchange exchange) { + @SuppressWarnings("unchecked") + private void createBroker(MqClient mqClient, Exchange exchange) { String brokerName; String brokerEngine; String brokerEngineVersion; diff --git a/components/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQComponentClientRegistryTest.java b/components/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQComponentClientRegistryTest.java index cfec1fe..c9c8e26 100644 --- a/components/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQComponentClientRegistryTest.java +++ b/components/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQComponentClientRegistryTest.java @@ -40,7 +40,7 @@ public class MQComponentClientRegistryTest extends CamelTestSupport { MQ2Component component = context.getComponent("aws2-mq", MQ2Component.class); assertThrows(IllegalArgumentException.class, () -> { - MQ2Endpoint endpoint = (MQ2Endpoint)component.createEndpoint("aws2-mq://MyQueue"); + component.createEndpoint("aws2-mq://MyQueue"); }); } }