@UriEndpoint(scheme="ignite:set", title="Ignite Sets", syntax="ignite:set:[name]", label="nosql,cache", producerOnly=true) public class IgniteSetEndpoint extends AbstractIgniteEndpoint
component
Constructor and Description |
---|
IgniteSetEndpoint(String endpointUri,
URI remainingUri,
Map<String,Object> parameters,
IgniteComponent igniteComponent) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
org.apache.ignite.configuration.CollectionConfiguration |
getConfiguration()
Gets the collection configuration.
|
String |
getName()
Gets the set name.
|
IgniteSetOperation |
getOperation()
Gets the set operation to perform.
|
void |
setConfiguration(org.apache.ignite.configuration.CollectionConfiguration configuration)
Sets the collection configuration.
|
void |
setName(String name)
Sets the set name.
|
void |
setOperation(IgniteSetOperation operation)
Sets the set operation to perform.
|
ignite, igniteComponent, isPropagateIncomingBodyIfNoReturnValue, isSingleton, isTreatCollectionsAsCacheObjects, setPropagateIncomingBodyIfNoReturnValue, setTreatCollectionsAsCacheObjects
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
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public String getName()
public void setName(String name)
name
- public org.apache.ignite.configuration.CollectionConfiguration getConfiguration()
public void setConfiguration(org.apache.ignite.configuration.CollectionConfiguration configuration)
You can also conveniently set inner properties by using configuration.xyz=123 options.
configuration
- public IgniteSetOperation getOperation()
public void setOperation(IgniteSetOperation operation)
operation
- Apache Camel