@UriEndpoint(scheme="chronicle-engine", title="Chronicle Engine", syntax="chronicle-engine:addresses/path", consumerClass=ChronicleEngineConsumer.class, label="Chronicle") public class ChronicleEngineEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
ChronicleEngineEndpoint(String uri,
ChronicleEngineComponent component,
ChronicleEngineConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected net.openhft.chronicle.engine.api.tree.AssetTree |
createRemoteAssetTree() |
protected void |
doStart() |
protected void |
doStop() |
protected ChronicleEngineConfiguration |
getConfiguration() |
protected String |
getPath() |
protected String |
getUri() |
boolean |
isSingleton() |
void |
setAddresses(String addresses) |
void |
setConfiguration(ChronicleEngineConfiguration configuration) |
void |
setPath(String path) |
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 ChronicleEngineEndpoint(String uri, ChronicleEngineComponent component, ChronicleEngineConfiguration configuration) throws Exception
Exception
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 void setAddresses(String addresses)
public void setPath(String path)
public void setConfiguration(ChronicleEngineConfiguration configuration)
protected ChronicleEngineConfiguration getConfiguration()
protected String getPath()
protected String getUri()
protected net.openhft.chronicle.engine.api.tree.AssetTree createRemoteAssetTree()
Apache Camel