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/02/21 11:16:43 UTC

[camel] branch master updated: Camel-AWS2-MQ: Correct the way we return errorCode

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 5a6c91c  Camel-AWS2-MQ: Correct the way we return errorCode
5a6c91c is described below

commit 5a6c91cb4f535f276b1710284c8591e64e1e00aa
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 21 12:15:39 2020 +0100

    Camel-AWS2-MQ: Correct the way we return errorCode
---
 .../java/org/apache/camel/component/aws2/mq/MQ2Producer.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 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 3b898bd..accadd9 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
@@ -120,7 +120,7 @@ public class MQ2Producer extends DefaultProducer {
         try {
             result = mqClient.listBrokers(builder.build());
         } catch (AwsServiceException ase) {
-            LOG.trace("List Brokers command returned the error code {}", ase.getMessage());
+            LOG.trace("List Brokers command returned the error code {}", ase.awsErrorDetails().errorCode());
             throw ase;
         }
         Message message = getMessageForResponse(exchange);
@@ -182,7 +182,7 @@ public class MQ2Producer extends DefaultProducer {
         try {
             result = mqClient.createBroker(builder.build());
         } catch (AwsServiceException ase) {
-            LOG.trace("Create Broker command returned the error code {}", ase.getMessage());
+            LOG.trace("Create Broker command returned the error code {}", ase.awsErrorDetails().errorCode());
             throw ase;
         }
         Message message = getMessageForResponse(exchange);
@@ -202,7 +202,7 @@ public class MQ2Producer extends DefaultProducer {
         try {
             result = mqClient.deleteBroker(builder.build());
         } catch (AwsServiceException ase) {
-            LOG.trace("Delete Broker command returned the error code {}", ase.getMessage());
+            LOG.trace("Delete Broker command returned the error code {}", ase.awsErrorDetails().errorCode());
             throw ase;
         }
         Message message = getMessageForResponse(exchange);
@@ -222,7 +222,7 @@ public class MQ2Producer extends DefaultProducer {
         try {
             result = mqClient.rebootBroker(builder.build());
         } catch (AwsServiceException ase) {
-            LOG.trace("Reboot Broker command returned the error code {}", ase.getMessage());
+            LOG.trace("Reboot Broker command returned the error code {}", ase.awsErrorDetails().errorCode());
             throw ase;
         }
         Message message = getMessageForResponse(exchange);
@@ -249,7 +249,7 @@ public class MQ2Producer extends DefaultProducer {
         try {
             result = mqClient.updateBroker(builder.build());
         } catch (AwsServiceException ase) {
-            LOG.trace("Update Broker command returned the error code {}", ase.getMessage());
+            LOG.trace("Update Broker command returned the error code {}", ase.awsErrorDetails().errorCode());
             throw ase;
         }
         Message message = getMessageForResponse(exchange);
@@ -269,7 +269,7 @@ public class MQ2Producer extends DefaultProducer {
         try {
             result = mqClient.describeBroker(builder.build());
         } catch (AwsServiceException ase) {
-            LOG.trace("Reboot Broker command returned the error code {}", ase.getMessage());
+            LOG.trace("Reboot Broker command returned the error code {}", ase.awsErrorDetails().errorCode());
             throw ase;
         }
         Message message = getMessageForResponse(exchange);