[camel] branch master updated: CAMEL-AWS MQ: Deployment Mode must be specified when we create the broker

[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 5ae6ca5  CAMEL-AWS MQ: Deployment Mode must be specified when we 
create the broker
5ae6ca5 is described below

commit 5ae6ca5525b9440bc35879d2a268a8d2868f2821
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Oct 3 14:23:58 2018 +0200

    CAMEL-AWS MQ: Deployment Mode must be specified when we create the broker
---
 .../src/main/java/org/apache/camel/component/aws/mq/MQProducer.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQProducer.java
 
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQProducer.java
index 87f7d3c..6e697e9 100644
--- 
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQProducer.java
+++ 
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQProducer.java
@@ -23,6 +23,7 @@ import com.amazonaws.services.mq.model.CreateBrokerRequest;
 import com.amazonaws.services.mq.model.CreateBrokerResult;
 import com.amazonaws.services.mq.model.DeleteBrokerRequest;
 import com.amazonaws.services.mq.model.DeleteBrokerResult;
+import com.amazonaws.services.mq.model.DeploymentMode;
 import com.amazonaws.services.mq.model.DescribeBrokerRequest;
 import com.amazonaws.services.mq.model.DescribeBrokerResult;
 import com.amazonaws.services.mq.model.ListBrokersRequest;
@@ -136,7 +137,9 @@ public class MQProducer extends DefaultProducer {
         }
         if 
(ObjectHelper.isNotEmpty(exchange.getIn().getHeader(MQConstants.BROKER_DEPLOYMENT_MODE)))
 {
             deploymentMode = 
exchange.getIn().getHeader(MQConstants.BROKER_DEPLOYMENT_MODE, String.class);
-            request.withDeploymentMode(deploymentMode);
+            
request.withDeploymentMode(DeploymentMode.fromValue(deploymentMode));
+        } else {
+            throw new IllegalArgumentException("Deployment Mode must be 
specified");
         }
         CreateBrokerResult result;
         try {