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 ec5f5a940c2f4be846d78f09bff5f61c728a0cd6 Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Aug 21 15:47:57 2018 +0200 Camel-Kubernetes: Align component to the new kubernetes-model --- .../component/kubernetes/services/KubernetesServicesConsumer.java | 3 ++- .../component/kubernetes/services/KubernetesServicesProducer.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesConsumer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesConsumer.java index 8b25131..3d8199e 100644 --- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesConsumer.java +++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesConsumer.java @@ -26,6 +26,7 @@ import io.fabric8.kubernetes.client.Watch; import io.fabric8.kubernetes.client.Watcher; import io.fabric8.kubernetes.client.dsl.MixedOperation; import io.fabric8.kubernetes.client.dsl.Resource; +import io.fabric8.kubernetes.client.dsl.ServiceResource; import org.apache.camel.Exchange; import org.apache.camel.Processor; @@ -91,7 +92,7 @@ public class KubernetesServicesConsumer extends DefaultConsumer { @Override public void run() { - MixedOperation<Service, ServiceList, DoneableService, Resource<Service, DoneableService>> w = getEndpoint().getKubernetesClient().services(); + MixedOperation<Service, ServiceList, DoneableService, ServiceResource<Service, DoneableService>> w = getEndpoint().getKubernetesClient().services(); if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getNamespace())) { w.inNamespace(getEndpoint().getKubernetesConfiguration().getNamespace()); } 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 bffb706..eaaf0a2 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 @@ -28,6 +28,7 @@ import io.fabric8.kubernetes.client.Watcher; import io.fabric8.kubernetes.client.dsl.FilterWatchListMultiDeletable; import io.fabric8.kubernetes.client.dsl.NonNamespaceOperation; import io.fabric8.kubernetes.client.dsl.Resource; +import io.fabric8.kubernetes.client.dsl.ServiceResource; import org.apache.camel.Exchange; import org.apache.camel.component.kubernetes.AbstractKubernetesEndpoint; @@ -117,7 +118,7 @@ public class KubernetesServicesProducer extends DefaultProducer { String namespaceName = exchange.getIn().getHeader( KubernetesConstants.KUBERNETES_NAMESPACE_NAME, String.class); if (!ObjectHelper.isEmpty(namespaceName)) { - NonNamespaceOperation<Service, ServiceList, DoneableService, Resource<Service, DoneableService>> services; + NonNamespaceOperation<Service, ServiceList, DoneableService, ServiceResource<Service, DoneableService>> services; services = getEndpoint().getKubernetesClient().services() .inNamespace(namespaceName); for (Map.Entry<String, String> entry : labels.entrySet()) {
