[camel] branch master updated: CAMEL-13079 - Camel-AWS EKS: Specify the VPC Config header correctly

[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 b2cbba5  CAMEL-13079 - Camel-AWS EKS: Specify the VPC Config header 
correctly
b2cbba5 is described below

commit b2cbba5ed97560afbbebc14c90591b2a86bc8705
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Jan 18 12:04:36 2019 +0100

    CAMEL-13079 - Camel-AWS EKS: Specify the VPC Config header correctly
---
 .../src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java
 
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java
index 90119be..9e94d6b 100644
--- 
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java
+++ 
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java
@@ -120,8 +120,8 @@ public class EKSProducer extends DefaultProducer {
             String roleArn = exchange.getIn().getHeader(EKSConstants.ROLE_ARN, 
String.class);
             request.withRoleArn(roleArn);
         }
-        if 
(ObjectHelper.isNotEmpty(exchange.getIn().getHeader(EKSConstants.ROLE_ARN))) {
-            VpcConfigRequest vpcConfig = 
exchange.getIn().getHeader(EKSConstants.ROLE_ARN, VpcConfigRequest.class);
+        if 
(ObjectHelper.isNotEmpty(exchange.getIn().getHeader(EKSConstants.VPC_CONFIG))) {
+            VpcConfigRequest vpcConfig = 
exchange.getIn().getHeader(EKSConstants.VPC_CONFIG, VpcConfigRequest.class);
             request.withResourcesVpcConfig(vpcConfig);
         }
         CreateClusterResult result;