@UriEndpoint(scheme="ignite:...",
title="Ignite endpoints",
syntax="ignite:...",
label="nosql,cache,compute",
producerOnly=true)
public abstract class AbstractIgniteEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Modifier and Type | Field and Description |
---|---|
protected IgniteComponent |
component |
Constructor and Description |
---|
AbstractIgniteEndpoint(String endpointUri,
org.apache.camel.Component component) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.ignite.Ignite |
ignite() |
protected IgniteComponent |
igniteComponent() |
boolean |
isPropagateIncomingBodyIfNoReturnValue()
Gets whether to propagate the incoming body if the return type of the underlying
Ignite operation is void.
|
boolean |
isSingleton() |
boolean |
isTreatCollectionsAsCacheObjects()
Gets whether to treat Collections as cache objects or as Collections of items to
insert/update/compute, etc.
|
void |
setPropagateIncomingBodyIfNoReturnValue(boolean propagateIncomingBodyIfNoReturnValue)
Sets whether to propagate the incoming body if the return type of the underlying
Ignite operation is void.
|
void |
setTreatCollectionsAsCacheObjects(boolean treatCollectionsAsCacheObjects)
Sets whether to treat Collections as cache objects or as Collections of items to
insert/update/compute, etc.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, 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
protected IgniteComponent component
public AbstractIgniteEndpoint(String endpointUri, org.apache.camel.Component component)
public boolean isSingleton()
protected IgniteComponent igniteComponent()
protected org.apache.ignite.Ignite ignite()
public boolean isPropagateIncomingBodyIfNoReturnValue()
public void setPropagateIncomingBodyIfNoReturnValue(boolean propagateIncomingBodyIfNoReturnValue)
propagateIncomingBodyIfNoReturnValue
- public boolean isTreatCollectionsAsCacheObjects()
public void setTreatCollectionsAsCacheObjects(boolean treatCollectionsAsCacheObjects)
treatCollectionsAsCacheObjects
- Apache Camel