public abstract class AbstractAtomixClientEndpoint<T extends AbstractAtomixClientComponent,C extends AtomixClientConfiguration>
extends org.apache.camel.impl.DefaultEndpoint
Modifier | Constructor and Description |
---|---|
protected |
AbstractAtomixClientEndpoint(String uri,
T component,
String resourceName) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
io.atomix.AtomixClient |
getAtomix() |
T |
getAtomixComponent() |
abstract C |
getConfiguration() |
String |
getResourceName() |
boolean |
isSingleton() |
abstract void |
setConfiguration(C configuration) |
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 boolean isSingleton()
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
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 T getAtomixComponent()
public io.atomix.AtomixClient getAtomix()
public String getResourceName()
public abstract C getConfiguration()
public abstract void setConfiguration(C configuration)
Apache Camel