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 2019/01/18 11:06:55 UTC

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

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 <an...@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;