public abstract class AbstractKubernetesEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
AbstractKubernetesEndpoint(String uri,
AbstractKubernetesComponent component,
KubernetesConfiguration config) |
Modifier and Type | Method and Description |
---|---|
ExecutorService |
createExecutor() |
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 AbstractKubernetesEndpoint(String uri, AbstractKubernetesComponent component, KubernetesConfiguration config)
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