[camel] branch master updated: Camel-AWS2-KMS: Cleanup

[acosentino]

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


The following commit(s) were added to refs/heads/master by this push:
     new b99bde6  Camel-AWS2-KMS: Cleanup
b99bde6 is described below

commit b99bde63edbfa2e70eea3ff7f8fbc674041f53e4
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Mar 17 17:27:28 2020 +0100

    Camel-AWS2-KMS: Cleanup
---
 .../java/org/apache/camel/component/aws2/kms/KMS2Producer.java     | 7 +------
 .../camel/component/aws2/kms/KMSComponentClientRegistryTest.java   | 2 +-
 2 files changed, 2 insertions(+), 7 deletions(-)

diff --git 
a/components/camel-aws2-kms/src/main/java/org/apache/camel/component/aws2/kms/KMS2Producer.java
 
b/components/camel-aws2-kms/src/main/java/org/apache/camel/component/aws2/kms/KMS2Producer.java
index 3caafb6..74ab670 100644
--- 
a/components/camel-aws2-kms/src/main/java/org/apache/camel/component/aws2/kms/KMS2Producer.java
+++ 
b/components/camel-aws2-kms/src/main/java/org/apache/camel/component/aws2/kms/KMS2Producer.java
@@ -223,11 +223,6 @@ public class KMS2Producer extends DefaultProducer {
     }
 
     public static Message getMessageForResponse(final Exchange exchange) {
-        if (exchange.getPattern().isOutCapable()) {
-            Message out = exchange.getOut();
-            out.copyFrom(exchange.getIn());
-            return out;
-        }
-        return exchange.getIn();
+        return exchange.getMessage();
     }
 }
diff --git 
a/components/camel-aws2-kms/src/test/java/org/apache/camel/component/aws2/kms/KMSComponentClientRegistryTest.java
 
b/components/camel-aws2-kms/src/test/java/org/apache/camel/component/aws2/kms/KMSComponentClientRegistryTest.java
index f6fe8fc..9d67731 100644
--- 
a/components/camel-aws2-kms/src/test/java/org/apache/camel/component/aws2/kms/KMSComponentClientRegistryTest.java
+++ 
b/components/camel-aws2-kms/src/test/java/org/apache/camel/component/aws2/kms/KMSComponentClientRegistryTest.java
@@ -40,7 +40,7 @@ public class KMSComponentClientRegistryTest extends 
CamelTestSupport {
 
         KMS2Component component = context.getComponent("aws2-kms", 
KMS2Component.class);
         assertThrows(IllegalArgumentException.class, () -> {
-            KMS2Endpoint endpoint = 
(KMS2Endpoint)component.createEndpoint("aws2-kms://TestDomain");
+            component.createEndpoint("aws2-kms://TestDomain");
         });
     }
 }