...
This endpoint only supports producers.
Options
Option | Type | Default value | Description | Compulsory | Consumer/producer |
---|---|---|---|---|---|
| IgniteComputeExecutionType enum | --- | The compute operation to perform. Possible values: CALL, BROADCAST, APPLY, EXECUTE, RUN, AFFINITY_CALL, AFFINITY_RUN. | Y | Producer |
| ClusterGroupExpression | --- | An expression that returns the Cluster Group for the IgniteCompute instance. | N | Producer |
| String | --- | The task name, only used when performing the EXECUTE if a ComputeTask is not passed in the payload. | N | Producer |
| String | --- | The name for the IgniteCompute instances produced by this endpoint. | N | Producer |
| Long |
| The timeout for the compute job. | N | Producer |
Headers used
Header name | Constant | Expected type | Description |
---|---|---|---|
| IgniteConstants.IGNITE_COMPUTE_EXECUTION_TYPE | IgniteComputeExecutionType enum | Allows you to dynamically change the compute operation to perform. |
| IgniteConstants.IGNITE_COMPUTE_PARAMS | Any object or Collection of objects. | Parameters for APPLY, BROADCAST and EXECUTE operations. |
| 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. |
| IgniteConstants.IGNITE_COMPUTE_AFFINITY_KEY | Object | Affinity key for the AFFINITY_CALL and AFFINITY_RUN operations. |
...
Expected payload 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. |
Ignite Messaging endpoint
The Ignite Messaging endpoint allows you to send and consume messages from an Ignite topic.
Code Block |
---|
ignite:messaging:topicName?option1=value1&option2=value2... |
This endpoint supports producers (to send messages) and consumers (to receive messages).
Options
Option | Type | Default value | Description | Compulsory | Consumer/producer |
---|---|---|---|---|---|
| IgniteComputeExecutionType enum | --- | The compute operation to perform. Possible values: CALL, BROADCAST, APPLY, EXECUTE, RUN, AFFINITY_CALL, AFFINITY_RUN. | Y | Producer |
| ClusterGroupExpression | --- | An expression that returns the Cluster Group for the IgniteCompute instance. | N | Producer |
| String | --- | The task name, only used when performing the EXECUTE if a ComputeTask is not passed in the payload. | N | Producer |
| String | --- | The name for the IgniteCompute instances produced by this endpoint. | N | Producer |
| Long |
| The timeout for the compute job. | N | Producer |
...
Ignite Events endpoint
The Ignite
...
Events endpoint allows you to receive events from the Ignite cluster by creating a local event listener.
Code Block |
---|
ignite:messagingevents:topicNameendpointId?option1=value1&option2=value2... |
This endpoint only supports consumers.
The Exchanges created by this consumer put the received Event
object into the body of the IN message.
Options
Ignite Events endpoint
Code Block |
---|
ignite:events:endpointId?option1=value1&option2=value2... |
Options
...
Option | Type | Default value | Description | Compulsory | Consumer/producer |
---|---|---|---|---|---|
| Set<Integer> or String | EventType.EVTS_ALL | The event IDs to subscribe to. You can set a For example: | N | Consumer |
| ClusterGroupExpression | --- | An expression that returns the Cluster Group to be used by the IgniteEvents instance. | N | Consumer |
Ignite Sets endpoint
The Ignite Sets endpoint allows you to interact with Ignite Set data structures.
Code Block |
---|
ignite:sets:setName?option1=value1&option2=value2... |
This endpoint only supports producers.
Options
Option | Type | Default value | Description | Compulsory | Consumer/producer |
---|---|---|---|---|---|
|
| --- | The operation to invoke on the Ignite Set. Superseded by the Possible values: | N | Producer |
| CollectionConfiguration | empty CollectionConfiguration | The configuration for this data structure. You can also specify inner properties by using the For example: | N | Producer |
Ignite Queue endpoint
The Ignite Queue endpoint allows you to interact with Ignite Queue data structures.
Code Block |
---|
ignite:queue:queueName?option1=value1&option2=value2... |
This endpoint only supports producers.
Options
Option | Type | Default value | Description | Compulsory | Consumer/producer |
---|---|---|---|---|---|
|
| --- | The operation to invoke on the Ignite Queue. Superseded by the Possible values: | N | Producer |
| CollectionConfiguration | empty CollectionConfiguration | The configuration for this data structure. You can also specify inner properties by using the For example: | N | Producer |
Ignite ID Generator endpoint
The Ignite ID Generator endpoint allows you to interact with Ignite Atomic Sequences and ID Generators.
Code Block |
---|
ignite:idgen:sequenceName?option1=value1&option2=value2... |
This endpoint only supports producers.
Options
Option | Type | Default value | Description | Compulsory | Consumer/producer |
---|---|---|---|---|---|
|
| --- | The operation to invoke on the Ignite ID Generator. Superseded by the Possible values: | N | Producer |
| CollectionConfiguration | empty CollectionConfiguration | The configuration for this data structure. You can also specify inner properties by using the For example: | N | Producer |
Initializing the Ignite component
...
Option | Type | Default value | Description |
---|---|---|---|
propagateIncomingBodyIfNoReturnValue | boolean | true | If the underlying Ignite operation returns void (no return type), this flag determines whether the producer will copy the IN body into the OUT body. |
treatCollectionsAsCacheObjects | boolean | false | Some Ignite operations can deal with multiple elements at once, if passed a Collection. Enabling this option will treat Collections as a single object, invoking the operation variant for cardinality 1. |
Include Page | ||||
---|---|---|---|---|
|