@UriEndpoint(scheme="ignite:queue", title="Ignite Queues", syntax="ignite:queue:[name]", label="nosql,cache", producerOnly=true) public class IgniteQueueEndpoint extends AbstractIgniteEndpoint
component
Constructor and Description |
---|
IgniteQueueEndpoint(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() |
int |
getCapacity()
Gets the queue capacity.
|
org.apache.ignite.configuration.CollectionConfiguration |
getConfiguration()
Gets the collection configuration.
|
String |
getName()
Gets the queue name.
|
IgniteQueueOperation |
getOperation()
Gets the queue operation to perform.
|
Long |
getTimeoutMillis()
Gets the queue timeout in milliseconds.
|
void |
setCapacity(int capacity)
Sets the queue capacity.
|
void |
setConfiguration(org.apache.ignite.configuration.CollectionConfiguration configuration)
Sets the collection configuration.
|
void |
setName(String name)
Sets the queue name.
|
void |
setOperation(IgniteQueueOperation operation)
Sets the queue operation to perform.
|
void |
setTimeoutMillis(Long timeoutMillis)
Sets the queue timeout in milliseconds.
|
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 IgniteQueueOperation getOperation()
public void setOperation(IgniteQueueOperation operation)
operation
- public int getCapacity()
public void setCapacity(int capacity)
capacity
- 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 Long getTimeoutMillis()
public void setTimeoutMillis(Long timeoutMillis)
timeoutMillis
- Apache Camel