@UriEndpoint(scheme="kubernetes",
title="Kubernetes",
syntax="kubernetes:masterUrl",
label="container,cloud,paas")
public class KubernetesEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
KubernetesEndpoint(String uri,
KubernetesComponent component,
KubernetesConfiguration config) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
ExecutorService |
createExecutor() |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
io.fabric8.kubernetes.client.KubernetesClient |
getKubernetesClient() |
KubernetesConfiguration |
getKubernetesConfiguration()
The kubernetes Configuration
|
boolean |
isSingleton() |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public KubernetesEndpoint(String uri, KubernetesComponent component, KubernetesConfiguration config)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
public ExecutorService createExecutor()
public io.fabric8.kubernetes.client.KubernetesClient getKubernetesClient()
public KubernetesConfiguration getKubernetesConfiguration()
Apache Camel