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);
}
}