Page History

...

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#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	Description
`CamelIgniteCacheKey`	`IgniteConstants.IGNITE_CACHE_KEY`	`String`	The cache key for the entry value in the message body.
`CamelIgniteCacheQuery`	`IgniteConstants.IGNITE_CACHE_QUERY`	`Query`	The query to run (producer) when invoking the QUERY operation.
`CamelIgniteCacheOperation`	`IgniteConstants.IGNITE_CACHE_OPERATION`	`IgniteCacheOperation enum`	Allows you to dynamically change the cache operation to execute (producer).
`CamelIgniteCachePeekMode`	`IgniteConstants.IGNITE_CACHE_PEEK_MODE`	`CachePeekMode enum`	Allows you to dynamically change the cache peek mode when running the SIZE operation.
`CamelIgniteCacheEventType`	`IgniteConstants.IGNITE_CACHE_EVENT_TYPE`	`int (EventType constants)`	This header carries the received event type when using the continuous query consumer.
`CamelIgniteCacheName`	`IgniteConstants.IGNITE_CACHE_NAME`	`String`	This header carries the cache name for which a continuous query event was received (consumer). It does not allow you to dynamically change the cache against which a producer operation is performed. Use EIPs for that (e.g. recipient list, dynamic router).
`CamelIgniteCacheOldValue`	`IgniteConstants.IGNITE_CACHE_OLD_VALUE`	`Object`	This header carries the old cache value when passed in the incoming cache event (consumer).

...

Option	Type	Default value	Description	Compulsory	Consumer/producer
`executionType`	`IgniteComputeExecutionType enum`	`---`	The compute operation to perform. Possible values: CALL, BROADCAST, APPLY APPLY, EXECUTE EXECUTE, RUN RUN, AFFINITY AFFINITY_CALL, AFFINITY 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

...

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:

...

Child pages

Versions Compared

Old Version 10

New Version 11

Key

Headers used

Expected payload types