public void apply()

in camel-k-master/impl/src/main/java/org/apache/camel/k/master/MasterContextCustomizer.java [41:67]


    public void apply(CamelContext camelContext) {
        try {
            KubernetesClusterService clusterService = new KubernetesClusterService();
            String resourceName = this.kubernetesResourceName;
            if (ObjectHelper.isEmpty(resourceName)) {
                resourceName = this.configMapName;
            }
            if (ObjectHelper.isNotEmpty(resourceName)) {
                clusterService.setKubernetesResourceName(resourceName);
            }
            if (ObjectHelper.isNotEmpty(this.labelKey) && ObjectHelper.isNotEmpty(this.labelValue)) {
                clusterService.setClusterLabels(Collections.singletonMap(this.labelKey, this.labelValue));
            }
            if (this.leaseResourceType != null) {
                clusterService.setLeaseResourceType(this.leaseResourceType);
            }

            if (this.rebalancing == null || this.rebalancing) {
                RebalancingCamelClusterService rebalancingService = new RebalancingCamelClusterService(clusterService, clusterService.getRenewDeadlineMillis());
                camelContext.addService(rebalancingService);
            } else {
                camelContext.addService(clusterService);
            }
        } catch (Exception ex) {
            throw new RuntimeCamelException(ex);
        }
    }