Page History

...

Offers both a Producer (to invoke cache operations on an Ignite cache) and a Consumer (to consume changes from a continuous query).

The cache value is always the body of the message, whereas the cache key is always stored in the IgniteConstants.IGNITE_CACHE_KEY message header.

Even if you configure a fixed operation in the endpoint URI, you can vary it per-exchange by setting the IgniteConstants.IGNITE_CACHE_OPERATION message header.

Options

Option	Type	Default value	Description	Compulsory	Consumer/producer
`operation`	IgniteCacheOperation enum	`---`	Cache operation to perform. Possible values: GET, PUT, REMOVE, SIZE, REBALANCE, QUERY, CLEAR.	N	Producer
`failIfInexistentCache`	boolean	`false`	Whether to fail the initialization if the cache doesn't exist.	N	Producer
`cachePeekMode`	CachePeekMode (Ignite) enum	`ALL`	The cache peek mode used for SIZE operations.	N	Producer
`query`	Query	`---`	The query used for QUERY operations (as a producer) or to launch the continuous query (as a consumer). You can use a reference to a registry bean with a syntax like: `?query=#myQuery`.	Y for the consumer N for the producer	Producer (for QUERY operation) and Consumer
`remoteFilter`	CacheEntryEventSerializableFilter	`---`	An optional remote filter for the continuous query consumer. You can use a reference to a registry bean with a syntax like: `?remoteFilter=#myRemoteFilter`.	N	Consumer
`oneExchangePerUpdate`	boolean	`true`	Whether to send one exchange per cache update, even if multiple changes arrive in a group.	N	Consumer
`fireExistingQueryResults`	boolean	`false`	When starting the continuous query consumer, whether to fire existing cache results.	N	Consumer
`autoUnsubscribe`	boolean	`ContinuousQuery.DFLT_AUTO_UNSUBSCRIBE`	Auto-unsubscribe flag on the Continuous Query (see Ignite docs).	N	Consumer
`pageSize`	int	`ContinuousQuery.DFLT_PAGE_SIZE`	Page size on the Continuous Query (see Ignite docs).	N	Consumer
`timeInterval`	long	`ContinuousQuery.DFLT_TIME_INTERVAL`	Time interval in millis on the Continuous Query (see Ignite docs).	N	Consumer

Headers used

This endpoint uses the following headers:

Header name	Constant	Expected type
`CamelIgniteCacheKey`	`IgniteConstants.IGNITE_CACHE_KEY`	`String`
`CamelIgniteCacheQuery`	`IgniteConstants.IGNITE_CACHE_QUERY`	`Query`
`CamelIgniteCacheOperation`	`IgniteConstants.IGNITE_CACHE_OPERATION`	`IgniteCacheOperation enum`
`CamelIgniteCachePeekMode`	`IgniteConstants.IGNITE_CACHE_PEEK_MODE`	`CachePeekMode enum`
`CamelIgniteCacheEventType`	`IgniteConstants.IGNITE_CACHE_EVENT_TYPE`	`int (EventType constants)`
`CamelIgniteCacheName`	`IgniteConstants.IGNITE_CACHE_NAME`	`String`
`CamelIgniteCacheOldValue`	`IgniteConstants.IGNITE_CACHE_OLD_VALUE`	`Object`

Ignite Compute endpoint

This endpoint allows you to run compute operations on the cluster by passing in an IgniteCallable, an IgniteRunnable, an IgniteClosure, or collections of them, along with their parameters if necessary.

...

This endpoint only supports producers.

The host part of the endpoint URI is a symbolic endpoint ID, it is not used for any purposes. The endpoint tries to run the object passed in the body of the IN message as the compute job. See below for expected payload types per operation.

Options

Option	Type	Default value	Description	Compulsory	Consumer/producer
`executionType`	`IgniteComputeExecutionType` enum	`---`	The compute operation to perform. Possible values: `CALL, BROADCAST, APPLY, EXECUTE, RUN, AFFINITY_CALL, AFFINITY_RUN`.	Y	Producer
`clusterGroupExpression`	ClusterGroupExpression	`---`	An expression that returns the Cluster Group for the IgniteCompute instance.	N	Producer
`taskName`	String	`---`	The task name, only used when performing the `EXECUTE` if a ComputeTask is not passed in the payload.	N	Producer
`computeName`	String	`---`	The name for the IgniteCompute instances produced by this endpoint.	N	Producer
`timeoutMillis`	Long	`---`	The timeout for the compute job.	N	Producer

Headers used

This endpoint uses the following headers:

Header name	Constant	Expected type	Description
`CamelIgniteComputeExecutionType`	`IgniteConstants.IGNITE_COMPUTE_EXECUTION_TYPE`	IgniteComputeExecutionType enum	Allows you to dynamically change the compute operation to perform.
`CamelIgniteComputeParameters`	`IgniteConstants.IGNITE_COMPUTE_PARAMS`	Any object or Collection of objects.	Parameters for APPLY, BROADCAST and EXECUTE operations.
`CamelIgniteComputeReducer`	`IgniteConstants.IGNITE_COMPUTE_REDUCER`	IgniteReducer	Reducer for the APPLY and CALL operations.
`CamelIgniteComputeAffinityCacheName`	`IgniteConstants.IGNITE_COMPUTE_AFFINITY_CACHE_NAME`	String	Affinity cache name for the AFFINITY_CALL and AFFINITY_RUN operations.
`CamelIgniteComputeAffinityKey`	`IgniteConstants.IGNITE_COMPUTE_AFFINITY_KEY`	Object	Affinity key for the AFFINITY_CALL and AFFINITY_RUN operations.

Expected payload types

Each operation expects the indicated types:

Operation	Expected payloads
CALL	Collection of IgniteCallable, or a single IgniteCallable.
BROADCAST	IgniteCallable, IgniteRunnable, IgniteClosure.
APPLY	IgniteClosure.
EXECUTE	ComputeTask, Class<? extends ComputeTask> or an object representing parameters if the taskName option is not null.
RUN	A Collection of IgniteRunnables, or a single IgniteRunnable.
AFFINITY_CALL	IgniteCallable.
AFFINITY_RUN	IgniteRunnable.

...

Child pages

Versions Compared

Old Version 6

New Version 7

Key

Options

Headers used

Ignite Compute endpoint

Options

Headers used

Expected payload types