You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/03/17 16:50:52 UTC
[camel] 01/02: Camel-AWS2-MQ: Cleanup
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 <an...@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");
});
}
}