From commits-return-61783-archive-asf-public=cust-asf.ponee.io@camel.apache.org Wed Mar 7 13:46:04 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id CE824180771 for ; Wed, 7 Mar 2018 13:46:02 +0100 (CET) Received: (qmail 927 invoked by uid 500); 7 Mar 2018 12:46:01 -0000 Mailing-List: contact commits-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@camel.apache.org Delivered-To: mailing list commits@camel.apache.org Received: (qmail 861 invoked by uid 99); 7 Mar 2018 12:46:01 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Mar 2018 12:46:01 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 19295826CB; Wed, 7 Mar 2018 12:46:01 +0000 (UTC) Date: Wed, 07 Mar 2018 12:46:01 +0000 To: "commits@camel.apache.org" Subject: [camel] 01/07: CAMEL-12328 - Headers getting lost after calling kubernetes-services API MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit From: acosentino@apache.org In-Reply-To: <152042676068.9952.11967789076912139232@gitbox.apache.org> References: <152042676068.9952.11967789076912139232@gitbox.apache.org> X-Git-Host: gitbox.apache.org X-Git-Repo: camel X-Git-Refname: refs/heads/master X-Git-Reftype: branch X-Git-Rev: 8ad1a302dced7ee86c6dcd767b1d2d46d542cf22 X-Git-NotificationType: diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated Message-Id: <20180307124601.19295826CB@gitbox.apache.org> 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 commit 8ad1a302dced7ee86c6dcd767b1d2d46d542cf22 Author: Andrea Cosentino AuthorDate: Wed Mar 7 13:35:27 2018 +0100 CAMEL-12328 - Headers getting lost after calling kubernetes-services API --- .../component/kubernetes/services/KubernetesServicesProducer.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java index 19e65b4..75ea760 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java @@ -35,6 +35,7 @@ import org.apache.camel.component.kubernetes.AbstractKubernetesEndpoint; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesOperations; import org.apache.camel.impl.DefaultProducer; +import org.apache.camel.util.MessageHelper; import org.apache.camel.util.ObjectHelper; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -105,6 +106,7 @@ public class KubernetesServicesProducer extends DefaultProducer { servicesList = getEndpoint().getKubernetesClient().services().inAnyNamespace() .list(); } + MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true); exchange.getOut().setBody(servicesList.getItems()); } @@ -131,6 +133,7 @@ public class KubernetesServicesProducer extends DefaultProducer { } servicesList = services.list(); } + MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true); exchange.getOut().setBody(servicesList.getItems()); } @@ -153,6 +156,7 @@ public class KubernetesServicesProducer extends DefaultProducer { } service = getEndpoint().getKubernetesClient().services() .inNamespace(namespaceName).withName(serviceName).get(); + MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true); exchange.getOut().setBody(service); } @@ -187,6 +191,7 @@ public class KubernetesServicesProducer extends DefaultProducer { .endMetadata().withSpec(serviceSpec).build(); service = getEndpoint().getKubernetesClient().services() .inNamespace(namespaceName).create(serviceCreating); + MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true); exchange.getOut().setBody(service); } @@ -208,6 +213,7 @@ public class KubernetesServicesProducer extends DefaultProducer { } boolean serviceDeleted = getEndpoint().getKubernetesClient().services() .inNamespace(namespaceName).withName(serviceName).delete(); + MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true); exchange.getOut().setBody(serviceDeleted); } } -- To stop receiving notification emails like this one, please contact acosentino@apache.org.