You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bu...@apache.org on 2016/01/30 07:30:37 UTC
svn commit: r979013 [2/4] - in /websites/production/camel/content: ./ cache/
ignite.data/ index.userimage/ news.userimage/ security-advisories.data/
Modified: websites/production/camel/content/ignite.html
==============================================================================
--- websites/production/camel/content/ignite.html (original)
+++ websites/production/camel/content/ignite.html Sat Jan 30 06:30:37 2016
@@ -85,29 +85,28 @@
<tbody>
<tr>
<td valign="top" width="100%">
-<div class="wiki-content maincontent"><h2 id="Ignite-CamelIgnitecomponent">Camel Ignite component</h2><p><strong>Available as of Camel 2.17</strong></p><p><a shape="rect" class="external-link" href="https://ignite.apache.org/">Apache Ignite</a> In-Memory Data Fabric is a high-performance, integrated and distributed in-memory platform for computing and transacting on large-scale data sets in real-time, orders of magnitude faster than possible with traditional disk-based or flash technologies. It is designed to deliver uncompromised performance for a wide set of in-memory computing use cases from high performance computing, to the industry most advanced data grid, highly available service grid, and streaming. See all <a shape="rect" class="external-link" href="https://ignite.apache.org/features.html">features</a>.</p><p>This component offers seven endpoints to cover much of Ignite's functionality:</p><ul><li>Ignite Cache.</li><li>Ignite Compute.</li><li>Ignite Messaging.</li><li>
Ignite Events.</li><li>Ignite Sets.</li><li>Ignite Queues.</li><li>Ignite ID Generator.</li></ul><p>To use this component, add the following dependency to your <code>pom.xml</code>:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+<div class="wiki-content maincontent"><h2 id="Ignite-CamelIgnitecomponent">Camel Ignite component</h2><p><strong>Available as of Camel 2.17</strong></p><p><a shape="rect" class="external-link" href="https://ignite.apache.org/">Apache Ignite</a> In-Memory Data Fabric is a high-performance, integrated and distributed in-memory platform for computing and transacting on large-scale data sets in real-time, orders of magnitude faster than possible with traditional disk-based or flash technologies. It is designed to deliver uncompromised performance for a wide set of in-memory computing use cases from high performance computing, to the industry most advanced data grid, highly available service grid, and streaming. See all <a shape="rect" class="external-link" href="https://ignite.apache.org/features.html">features</a>.</p><p><span class="confluence-embedded-file-wrapper confluence-embedded-manual-size"><img class="confluence-embedded-image" height="250" src="ignite.data/apache-ignite%
20%281%29.png" data-image-src="/confluence/download/attachments/61333868/apache-ignite%20%281%29.png?version=1&modificationDate=1454001897000&api=v2" data-unresolved-comment-count="0" data-linked-resource-id="61338038" data-linked-resource-version="1" data-linked-resource-type="attachment" data-linked-resource-default-alias="apache-ignite (1).png" data-base-url="https://cwiki.apache.org/confluence" data-linked-resource-content-type="image/png" data-linked-resource-container-id="61333868" data-linked-resource-container-version="16"></span></p><p>This component offers seven endpoints to cover much of Ignite's functionality:</p><ul><li>Ignite Cache.</li><li>Ignite Compute.</li><li>Ignite Messaging.</li><li>Ignite Events.</li><li>Ignite Sets.</li><li>Ignite Queues.</li><li>Ignite ID Generator.</li></ul><p><strong>To use this component</strong>, add the following dependency to your <code>pom.xml</code>:</p><div class="code panel pdl" style="border-width: 1px;"><div clas
s="codeContent panelContent pdl">
<script class="brush: xml; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-ignite</artifactId>
<version>${camel.version}</version> <!-- use the same version as your Camel core version -->
-</dependency>
-]]></script>
-</div></div><h2 id="Ignite-URIformatsandoptions">URI formats and options</h2><h3 id="Ignite-IgniteCacheendpoint">Ignite Cache endpoint</h3><p>This endpoint allows you to interact with an <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/data-grid" style="line-height: 1.42857;" rel="nofollow">Ignite Cache</a>:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+</dependency>]]></script>
+</div></div><h2 id="Ignite-Tableofcontents">Table of contents</h2><p></p><div class="toc-macro client-side-toc-macro" data-headerelements="H1,H2" data-excludeheaderregex=".*(Camel Ignite component|Table of contents).*"></div><h2 id="Ignite-CACHE:IgniteCacheendpoint">CACHE: Ignite Cache endpoint</h2><p>This endpoint allows you to interact with an <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/data-grid" style="line-height: 1.42857;" rel="nofollow">Ignite Cache</a>:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ignite:cache:cacheName?option1=value1&option2=value2...]]></script>
-</div></div><p>Offers both a Producer (to invoke cache operations on an Ignite cache) and a Consumer (to consume changes from a continuous query).</p><p>The cache value is always the body of the message, whereas the cache key is always stored in the <span><code>IgniteConstants.IGNITE_CACHE_KEY</code> message header. </span></p><p><span>Even if you configure a fixed operation in the endpoint URI, you can vary it per-exchange by setting the <code>IgniteConstants.IGNITE_CACHE_OPERATION</code> message header.</span></p><h4 id="Ignite-Options">Options</h4><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consum
er/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>operation</code></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteCacheOperation enum</td><td colspan="1" rowspan="1" class="confluenceTd">---</td><td colspan="1" rowspan="1" class="confluenceTd"><p>Cache operation to perform.</p><p>Possible values: GET, PUT, REMOVE, SIZE, REBALANCE, QUERY, CLEAR.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>failIfInexistentCache</code></td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd">Whether to fail the initialization if the cache doesn't exist.</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan
="1" rowspan="1" class="confluenceTd"><code>cachePeekMode</code></td><td colspan="1" rowspan="1" class="confluenceTd">CachePeekMode (Ignite) enum</td><td colspan="1" rowspan="1" class="confluenceTd">ALL</td><td colspan="1" rowspan="1" class="confluenceTd">The cache peek mode used for SIZE operations.</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span>Producer</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>query</code></td><td colspan="1" rowspan="1" class="confluenceTd">Query</td><td colspan="1" rowspan="1" class="confluenceTd">---</td><td colspan="1" rowspan="1" class="confluenceTd"><p>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.</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><span>Y for the consumer / </span>N for the producer</p>
</td><td colspan="1" rowspan="1" class="confluenceTd">Producer (for QUERY operation) and Consumer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>remoteFilter</code></td><td colspan="1" rowspan="1" class="confluenceTd">CacheEntryEventSerializableFilter</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">---</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>An optional remote filter for the continuous query consumer. You can use a reference to a registry bean with a syntax like: ?remoteFilter=#myRemoteFilter.</p></td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd">Consumer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>oneExchangePerUpdate</code></td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd">true</td><td colspan="1" rowspan="1" class="confluenceTd">Whether to send one exchange per cac
he update, even if multiple changes arrive in a group.</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd">Consumer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>fireExistingQueryResults</code></td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd">When starting the continuous query consumer, whether to fire existing cache results.</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span>Consumer</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>autoUnsubscribe</code></td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">ContinuousQuery.DFLT_AUTO_UNSUBSCRIBE</p></td><td colspan="1" rowspan="1" class="confluenceT
d">Auto-unsubscribe flag on the Continuous Query (see Ignite docs).</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span>Consumer</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>pageSize</code></td><td colspan="1" rowspan="1" class="confluenceTd">int</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">ContinuousQuery.DFLT_PAGE_SIZE</p></td><td colspan="1" rowspan="1" class="confluenceTd">Page size on the Continuous Query (see Ignite docs).</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span>Consumer</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>timeInterval</code></td><td colspan="1" rowspan="1" class="confluenceTd">long</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">ContinuousQuery.DFLT_TIME_INTERVAL</p></td><td colspan="1" rowspan="1" class="con
fluenceTd">Time interval in millis on the Continuous Query (see Ignite docs).</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span>Consumer</span></td></tr></tbody></table></div><h4 id="Ignite-Headersused">Headers used</h4><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteCacheKey</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_KEY</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" class="conflue
nceTd">The cache key for the entry value in the message body.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheQuery</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_QUERY</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Query</code></td><td colspan="1" rowspan="1" class="confluenceTd">The query to run (producer) when invoking the QUERY operation.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheOperation</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_OPERATION</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteCacheOperation enum</code></td><td colspan="1" rowspan="1" class="confluenceTd">Allows you to dynamically change the cache operation to execute (producer).</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCachePeekMode</code></td><td colspan="1" ro
wspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_PEEK_MODE</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>CachePeekMode enum</code></td><td colspan="1" rowspan="1" class="confluenceTd">Allows you to dynamically change the cache peek mode when running the SIZE operation.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheEventType</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_EVENT_TYPE</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>int (EventType constants)</code></td><td colspan="1" rowspan="1" class="confluenceTd">This header carries the received event type when using the continuous query consumer.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheName</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_NAME</code></td><td colspan="1" rowspan="1" class="confluenceTd"><co
de>String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>This header carries the cache name for which a continuous query event was received (consumer).</p><p>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).</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheOldValue</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_OLD_VALUE</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Object</code></td><td colspan="1" rowspan="1" class="confluenceTd">This header carries the old cache value when passed in the incoming cache event (consumer).</td></tr></tbody></table></div><h3 id="Ignite-IgniteComputeendpoint">Ignite Compute endpoint</h3><p>This endpoint allows you to run <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/compute-grid" style="lin
e-height: 1.42857;" rel="nofollow">compute operations</a> on the cluster by passing in an IgniteCallable, an IgniteRunnable, an IgniteClosure, or collections of them, along with their parameters if necessary. </p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ignite:compute:endpointId?option1=value1&option2=value2...]]></script>
-</div></div><p>This endpoint only supports producers.</p><p>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.</p><h4 id="Ignite-Options.1">Options</h4><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>executionType</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteComputeExecutionType en
um</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The compute operation to perform. Possible values: CALL, BROADCAST, APPLY, EXECUTE, RUN, AFFINITY_CALL, AFFINITY_RUN.</p></td><td colspan="1" rowspan="1" class="confluenceTd">Y</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>clusterGroupExpression</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>ClusterGroupExpression</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>An expression that returns the Cluster Group for the IgniteCompute instance.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p
class="p1"><code>taskName</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd">The task name, only used when performing the EXECUTE if a ComputeTask is not passed in the payload.</td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>computeName</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The name for the IgniteCompute instances produced by this endpoint.</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>N</p></td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class
="confluenceTd"><p class="p1"><code>timeoutMillis</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Long</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>---</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The timeout for the compute job.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr></tbody></table></div><h4 id="Ignite-Headersused.1">Headers used</h4><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteComputeExecutionType</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_EXECUTION_TYPE</code></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteComputeExecutionType enum</td><td colspan="1" rowspan="1" class="confluenceTd">Allows you to dynamically change the compute operation to perform.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteComputeParameters </code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_PARAMS</code></td><td colspan="1" rowspan="1" class="confluenceTd">Any object or Collection of objects.</td><td colspan="1" rowspan="1" class="confluenceTd">Parameters for APPLY, BROADCAST and EXECUTE operations.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteComputeReducer</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_REDUCER</code></td><td colspan="1"
rowspan="1" class="confluenceTd">IgniteReducer</td><td colspan="1" rowspan="1" class="confluenceTd">Reducer for the APPLY and CALL operations.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteComputeAffinityCacheName</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_AFFINITY_CACHE_NAME</code></td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd">Affinity cache name for the AFFINITY_CALL and AFFINITY_RUN operations.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteComputeAffinityKey</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_AFFINITY_KEY</code></td><td colspan="1" rowspan="1" class="confluenceTd">Object</td><td colspan="1" rowspan="1" class="confluenceTd">Affinity key for the AFFINITY_CALL and AFFINITY_RUN operations.</td></tr></tbody></table></div><
h4 id="Ignite-Expectedpayloadtypes">Expected payload types</h4><p>Each operation expects the indicated types:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Operation</th><th colspan="1" rowspan="1" class="confluenceTh">Expected payloads</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>CALL</pre></td><td colspan="1" rowspan="1" class="confluenceTd">Collection of IgniteCallable, or a single IgniteCallable.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>BROADCAST</pre></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteCallable, IgniteRunnable, IgniteClosure.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>APPLY</pre></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteClosure.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>EXECUTE</pre></td><td colspan="1" rowspan="1" class="confluenceTd">ComputeTask, Class<? extends Com
puteTask> or an object representing parameters if the taskName option is not null.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>RUN</pre></td><td colspan="1" rowspan="1" class="confluenceTd">A Collection of IgniteRunnables, or a single IgniteRunnable.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>AFFINITY_CALL</pre></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteCallable.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>AFFINITY_RUN</pre></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteRunnable.</td></tr></tbody></table></div><h4 id="Ignite-IgniteMessagingendpoint"><span style="line-height: 1.42857;">Ignite Messaging endpoint</span></h4><p><span style="line-height: 1.42857;"> </span>The Ignite Messaging endpoint allows you to send and consume messages from an <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/messaging" rel="nofollow">Ignite topic</a>.</p><div cla
ss="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+</div></div><p>Offers both a Producer (to invoke cache operations on an Ignite cache) and a Consumer (to consume changes from a continuous query).</p><p>The cache value is always the body of the message, whereas the cache key is always stored in the <span><code>IgniteConstants.IGNITE_CACHE_KEY</code> message header. </span></p><p><span>Even if you configure a fixed operation in the endpoint URI, you can vary it per-exchange by setting the <code>IgniteConstants.IGNITE_CACHE_OPERATION</code> message header.</span></p><h4 id="Ignite-Options">Options</h4><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consum
er/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>operation</code></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteCacheOperation enum</td><td colspan="1" rowspan="1" class="confluenceTd">---</td><td colspan="1" rowspan="1" class="confluenceTd"><p>Cache operation to perform.</p><p>Possible values: GET, PUT, REMOVE, SIZE, REBALANCE, QUERY, CLEAR.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>failIfInexistentCache</code></td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd">Whether to fail the initialization if the cache doesn't exist.</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan
="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>cachePeekMode</code></td><td colspan="1" rowspan="1" class="confluenceTd">CachePeekMode (Ignite) enum</td><td colspan="1" rowspan="1" class="confluenceTd">ALL</td><td colspan="1" rowspan="1" class="confluenceTd">The cache peek mode used for SIZE operations.</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>query</code></td><td colspan="1" rowspan="1" class="confluenceTd">Query</td><td colspan="1" rowspan="1" class="confluenceTd">---</td><td colspan="1" rowspan="1" class="confluenceTd"><p>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 reg
istry bean with a syntax like: ?query=#myQuery.</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><span>Y for the consumer / </span>N for the producer</p></td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong> (for QUERY operation) and <span style="color: rgb(0,0,255);"><strong>Consumer</strong></span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>remoteFilter</code></td><td colspan="1" rowspan="1" class="confluenceTd">CacheEntryEventSerializableFilter</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">---</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>An optional remote filter for the continuous query consumer. You can use a reference to a registry bean with a syntax like: ?remoteFilter=#myRemoteFilter.</p></td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255
);"><strong>Consumer</strong></span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>oneExchangePerUpdate</code></td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd">true</td><td colspan="1" rowspan="1" class="confluenceTd">Whether to send one exchange per cache update, even if multiple changes arrive in a group.</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255);"><strong>Consumer</strong></span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>fireExistingQueryResults</code></td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd">When starting the continuous query consumer, whether to fire existing cache results.</td><td colspan="1" rowspan="1" class="confluenceTd"><
span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255);"><strong>Consumer</strong></span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>autoUnsubscribe</code></td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">ContinuousQuery.DFLT_AUTO_UNSUBSCRIBE</p></td><td colspan="1" rowspan="1" class="confluenceTd">Auto-unsubscribe flag on the Continuous Query (see Ignite docs).</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255);"><strong>Consumer</strong></span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>pageSize</code></td><td colspan="1" rowspan="1" class="confluenceTd">int</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">ContinuousQuery.DFLT_PAGE_SIZE</p></td><td colspan="1" rowspan="1" class="confluenceTd
">Page size on the Continuous Query (see Ignite docs).</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255);"><strong>Consumer</strong></span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>timeInterval</code></td><td colspan="1" rowspan="1" class="confluenceTd">long</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">ContinuousQuery.DFLT_TIME_INTERVAL</p></td><td colspan="1" rowspan="1" class="confluenceTd">Time interval in millis on the Continuous Query (see Ignite docs).</td><td colspan="1" rowspan="1" class="confluenceTd"><span>N</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255);"><strong>Consumer</strong></span></td></tr></tbody></table></div><h4 id="Ignite-Headersused">Headers used</h4><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><t
h colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteCacheKey</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_KEY</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" class="confluenceTd">The cache key for the entry value in the message body.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheQuery</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_QUERY</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Query</code></td><td colspan="1" rowspan="1" class="confluenceTd">The query to run (producer)
when invoking the QUERY operation.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheOperation</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_OPERATION</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteCacheOperation enum</code></td><td colspan="1" rowspan="1" class="confluenceTd">Allows you to dynamically change the cache operation to execute (producer).</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCachePeekMode</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_PEEK_MODE</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>CachePeekMode enum</code></td><td colspan="1" rowspan="1" class="confluenceTd">Allows you to dynamically change the cache peek mode when running the SIZE operation.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheEventType</code></td><
td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_EVENT_TYPE</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>int (EventType constants)</code></td><td colspan="1" rowspan="1" class="confluenceTd">This header carries the received event type when using the continuous query consumer.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteCacheName</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_NAME</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>This header carries the cache name for which a continuous query event was received (consumer).</p><p>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).</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIg
niteCacheOldValue</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_CACHE_OLD_VALUE</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Object</code></td><td colspan="1" rowspan="1" class="confluenceTd">This header carries the old cache value when passed in the incoming cache event (consumer).</td></tr></tbody></table></div><h2 id="Ignite-COMPUTE:IgniteComputeendpoint">COMPUTE: Ignite Compute endpoint</h2><p>This endpoint allows you to run <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/compute-grid" style="line-height: 1.42857;" rel="nofollow">compute operations</a> on the cluster by passing in an IgniteCallable, an IgniteRunnable, an IgniteClosure, or collections of them, along with their parameters if necessary. </p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ignite:compute:endpointId?executionType=...&option1=value1&option2=value2...]]></script>
+</div></div><p>This endpoint only supports producers.</p><p>The host part of the endpoint URI is a symbolic endpoint ID, it is not used for any purposes.</p><p>The endpoint tries to run the object passed in the body of the IN message as the compute job. It expects different payload types depending on the execution type.</p><h4 id="Ignite-Expectedpayloadtypes">Expected payload types</h4><p>Each operation expects the indicated types:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Operation</th><th colspan="1" rowspan="1" class="confluenceTh">Expected payloads</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>CALL</pre></td><td colspan="1" rowspan="1" class="confluenceTd">Collection of IgniteCallable, or a single IgniteCallable.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>BROADCAST</pre></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteCallable, IgniteRunnable, Ignit
eClosure.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>APPLY</pre></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteClosure.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>EXECUTE</pre></td><td colspan="1" rowspan="1" class="confluenceTd">ComputeTask, Class<? extends ComputeTask> or an object representing parameters if the taskName option is not null.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>RUN</pre></td><td colspan="1" rowspan="1" class="confluenceTd">A Collection of IgniteRunnables, or a single IgniteRunnable.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>AFFINITY_CALL</pre></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteCallable.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><pre>AFFINITY_RUN</pre></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteRunnable.</td></tr></tbody></table></div><h4 id="Ignite-Options.1">Options</h4><div class="ta
ble-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>executionType</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteComputeExecutionType enum</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The compute operation to perform. Possible values: CALL, BROADCAST, APPLY, EXECUTE, RUN, AFFINITY_CALL, AFFINITY_RUN.</p><p>The component expects different payload types depending on the ope
ration. See above.</p></td><td colspan="1" rowspan="1" class="confluenceTd">Y</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>clusterGroupExpression</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>ClusterGroupExpression</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>An expression that returns the Cluster Group for the IgniteCompute instance.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>taskName</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" cla
ss="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd">The task name, only used when performing the EXECUTE if a ComputeTask is not passed in the payload.</td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>computeName</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The name for the IgniteCompute instances produced by this endpoint.</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>N</p></td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1
"><code>timeoutMillis</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Long</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>---</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The timeout for the compute job.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr></tbody></table></div><h4 id="Ignite-Headersused.1">Headers used</h4><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIg
niteComputeExecutionType</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_EXECUTION_TYPE</code></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteComputeExecutionType enum</td><td colspan="1" rowspan="1" class="confluenceTd">Allows you to dynamically change the compute operation to perform.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteComputeParameters </code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_PARAMS</code></td><td colspan="1" rowspan="1" class="confluenceTd">Any object or Collection of objects.</td><td colspan="1" rowspan="1" class="confluenceTd">Parameters for APPLY, BROADCAST and EXECUTE operations.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteComputeReducer</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_REDU
CER</code></td><td colspan="1" rowspan="1" class="confluenceTd">IgniteReducer</td><td colspan="1" rowspan="1" class="confluenceTd">Reducer for the APPLY and CALL operations.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteComputeAffinityCacheName</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_AFFINITY_CACHE_NAME</code></td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd">Affinity cache name for the AFFINITY_CALL and AFFINITY_RUN operations.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteComputeAffinityKey</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_COMPUTE_AFFINITY_KEY</code></td><td colspan="1" rowspan="1" class="confluenceTd">Object</td><td colspan="1" rowspan="1" class="confluenceTd">Affinity key for the AFFINITY_CALL and AFFINITY_RUN operations.</
td></tr></tbody></table></div><h4 id="Ignite-MESSAGING:IgniteMessagingendpoint"><span style="line-height: 1.42857;font-size: 20.0px;font-weight: normal;">MESSAGING: Ignite Messaging endpoint</span></h4><p><span style="line-height: 1.42857;"> </span>The Ignite Messaging endpoint allows you to send and consume messages from an <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/messaging" rel="nofollow">Ignite topic</a>.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ignite:messaging:topicName?option1=value1&option2=value2...]]></script>
-</div></div><p>This endpoint supports producers (to send messages) and consumers (to receive messages).</p><h4 id="Ignite-Options.2">Options</h4><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>clusterGroupExpression</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>ClusterGroupExpression</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>An expression that returns the Cluster Group for the IgniteMessaging insta
nce.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Consumer and Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>sendMode</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteMessagingSendMode enum</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><span style="font-family: monospace;">UNORDERED</span></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The send mode to use.</p><p>Possible values: <code>UNORDERED, ORDERED</code>.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>timeout</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p><code>Long</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>---</code></p></td><td colspan="1" rowspan="1" class="confluence
Td"><p>The timeout for the send operation when using ordered messages.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr></tbody></table></div><h4 id="Ignite-Headersused.2">Headers used</h4><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteMessagingTopic</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_MESSAGING_TOPIC</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>Allow
s you to dynamically change the topic to send messages to (producer). <br clear="none">It also carries the topic on which a message was received (consumer).</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteMessagingUUID</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_MESSAGING_UUID</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>UUID</code></td><td colspan="1" rowspan="1" class="confluenceTd">This header is filled in with the UUID of the subscription when a message arrives (consumer).</td></tr></tbody></table></div><h3 id="Ignite-IgniteEventsendpoint">Ignite Events endpoint</h3><p>The Ignite Events endpoint allows you to <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/events" rel="nofollow">receive events</a> from the Ignite cluster by creating a local event listener.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeC
ontent panelContent pdl">
+</div></div><p>This endpoint supports producers (to send messages) and consumers (to receive messages).</p><h3 id="Ignite-Options.2">Options</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>clusterGroupExpression</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>ClusterGroupExpression</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>An expression that returns the Cluster Group for the IgniteMessaging insta
nce.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255);"><strong>Consumer</strong></span> and <strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>sendMode</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteMessagingSendMode enum</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><span style="font-family: monospace;">UNORDERED</span></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The send mode to use.</p><p>Possible values: <code>UNORDERED, ORDERED</code>.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>timeout</code></td><td colspan="1" rowspan="1" class=
"confluenceTd"><p><code>Long</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>---</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The timeout for the send operation when using ordered messages.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr></tbody></table></div><h3 id="Ignite-Headersused.2">Headers used</h3><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteMessagingTopic</code></p></td
><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_MESSAGING_TOPIC</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>Allows you to dynamically change the topic to send messages to (producer). <br clear="none">It also carries the topic on which a message was received (consumer).</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteMessagingUUID</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_MESSAGING_UUID</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>UUID</code></td><td colspan="1" rowspan="1" class="confluenceTd">This header is filled in with the UUID of the subscription when a message arrives (consumer).</td></tr></tbody></table></div><h2 id="Ignite-EVENTS:IgniteEventsendpoint">EVENTS: Ignite Events endpoint</h2><p>The Ignite Events endpoint allows you to <a sha
pe="rect" class="external-link" href="https://apacheignite.readme.io/docs/events" rel="nofollow">receive events</a> from the Ignite cluster by creating a local event listener.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ignite:events:endpointId?option1=value1&option2=value2...]]></script>
-</div></div><p>This endpoint only supports consumers.</p><p>The Exchanges created by this consumer put the received <code>Event</code> object into the body of the IN message.</p><h4 id="Ignite-Options.3">Options</h4><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>events</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Set<Integer> or String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>EventType.EVTS_ALL</code></p></td><td colspan="1" rowspan="1" clas
s="confluenceTd"><p>The event IDs to subscribe to. You can set a <code>Set<Integer></code> directly where the IDs are the different constants in <code>org.apache.ignite.events.EventType</code>, or you can specify a comma-separated list of constant names.<br clear="none">For example: <code style="line-height: 1.42857;">EVT_CACHE_ENTRY_CREATED,EVT_CACHE_OBJECT_REMOVED,EVT_IGFS_DIR_CREATED</code>.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Consumer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>clusterGroupExpression</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>ClusterGroupExpression</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p><code>---</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>An expression that returns the Cluster Group to be used by the IgniteEvents instance.</p></td><td colspan="1" rowspan="1" class="confl
uenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Consumer</td></tr></tbody></table></div><h3 id="Ignite-IgniteSetsendpoint">Ignite Sets endpoint</h3><p>The Ignite Sets endpoint allows you to interact with <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/queue-and-set" rel="nofollow">Ignite Set data structures</a>.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+</div></div><p>This endpoint only supports consumers.</p><p>The Exchanges created by this consumer put the received <code>Event</code> object into the body of the IN message.</p><h3 id="Ignite-Options.3">Options</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>events</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Set<Integer> or String</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>EventType.EVTS_ALL</code></p></td><td colspan="1" rowspan="1" clas
s="confluenceTd"><p>The event IDs to subscribe to. You can set a <code>Set<Integer></code> directly where the IDs are the different constants in <code>org.apache.ignite.events.EventType</code>, or you can specify a comma-separated list of constant names.<br clear="none">For example: <code style="line-height: 1.42857;">EVT_CACHE_ENTRY_CREATED,EVT_CACHE_OBJECT_REMOVED,EVT_IGFS_DIR_CREATED</code>.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255);"><strong>Consumer</strong></span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>clusterGroupExpression</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>ClusterGroupExpression</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p><code>---</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>An expression that returns the Cluster Group to be used by the IgniteEvents
instance.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><span style="color: rgb(0,0,255);"><strong>Consumer</strong></span></td></tr></tbody></table></div><h2 id="Ignite-SETS:IgniteSetsendpoint">SETS: Ignite Sets endpoint</h2><p>The Ignite Sets endpoint allows you to interact with <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/queue-and-set" rel="nofollow">Ignite Set data structures</a>.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ignite:sets:setName?option1=value1&option2=value2...]]></script>
-</div></div><p>This endpoint only supports producers.</p><h4 id="Ignite-Options.4">Options</h4><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>operation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteSetOperation enum</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The operation to invoke on the Ignite Set.<br clear="none">Superseded by the <code style="line-height: 1.42857;">Ignit
eConstants.IGNITE_SETS_OPERATION</code> header in the IN message.<br clear="none">Possible values: <code style="line-height: 1.42857;">CONTAINS<span class="s1" style="line-height: 1.42857;">,</span> ADD<span class="s1" style="line-height: 1.42857;">,</span> SIZE<span class="s1" style="line-height: 1.42857;">,</span> REMOVE<span class="s1" style="line-height: 1.42857;">,</span> ITERATOR<span class="s1" style="line-height: 1.42857;">,</span> CLEAR<span class="s1" style="line-height: 1.42857;">,</span> RETAIN_ALL<span class="s1" style="line-height: 1.42857;">,</span> ARRAY</code>.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>configuration</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>CollectionConfiguration</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>empty CollectionConfiguration</code
></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The configuration for this data structure. You can also specify inner properties by using the <code>config.</code> prefix.</p><p>For example: <code>?config.backups=4</code></p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr></tbody></table></div><h4 id="Ignite-Headersused.3">Headers used</h4><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteSetsOperation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.<span
style="line-height: 1.42857;">IGNITE_SETS_OPERATION</span></code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteSetOperation</code><span> enum</span></td><td colspan="1" rowspan="1" class="confluenceTd"><p>Allows you to dynamically change the set operation.</p></td></tr></tbody></table></div><h3 id="Ignite-IgniteQueueendpoint">Ignite Queue endpoint</h3><p>The Ignite Queue endpoint allows you to interact with <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/queue-and-set" rel="nofollow">Ignite Queue data structures</a>.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+</div></div><p>This endpoint only supports producers.</p><h3 id="Ignite-Options.4">Options</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>operation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteSetOperation enum</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>---</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The operation to invoke on the Ignite Set.<br clear="none">Superseded by the <code style="line-height: 1.42857;">Ignit
eConstants.IGNITE_SETS_OPERATION</code> header in the IN message.<br clear="none">Possible values: <code style="line-height: 1.42857;">CONTAINS<span class="s1" style="line-height: 1.42857;">,</span> ADD<span class="s1" style="line-height: 1.42857;">,</span> SIZE<span class="s1" style="line-height: 1.42857;">,</span> REMOVE<span class="s1" style="line-height: 1.42857;">,</span> ITERATOR<span class="s1" style="line-height: 1.42857;">,</span> CLEAR<span class="s1" style="line-height: 1.42857;">,</span> RETAIN_ALL<span class="s1" style="line-height: 1.42857;">,</span> ARRAY</code>.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>configuration</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>CollectionConfiguration</code></td><td colspan="1" rowspan="1" cla
ss="confluenceTd"><code>empty CollectionConfiguration</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The configuration for this data structure. You can also specify inner properties by using the <code>config.</code> prefix.</p><p>For example: <code>?config.backups=4</code></p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr></tbody></table></div><h3 id="Ignite-Headersused.3">Headers used</h3><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><cod
e>CamelIgniteSetsOperation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.<span style="line-height: 1.42857;">IGNITE_SETS_OPERATION</span></code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteSetOperation</code><span> enum</span></td><td colspan="1" rowspan="1" class="confluenceTd"><p>Allows you to dynamically change the set operation.</p></td></tr></tbody></table></div><h2 id="Ignite-QUEUE:IgniteQueueendpoint">QUEUE: Ignite Queue endpoint</h2><p>The Ignite Queue endpoint allows you to interact with <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/queue-and-set" rel="nofollow">Ignite Queue data structures</a>.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ignite:queue:queueName?option1=value1&option2=value2...
]]></script>
-</div></div><p>This endpoint only supports producers.</p><h4 id="Ignite-Options.5">Options</h4><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>operation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteQueueOperation</code> enum</p></td><td colspan="1" rowspan="1" class="confluenceTd"><pre class="p1">---</pre></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The operation to invoke on the Ignite Queue.</p><p>Superseded by the <code>IgniteConstants.IGNITE_QUEUE_OPE
RATION</code> header in the IN message.</p><p>Possible values: <code>CONTAINS<span class="s1" style="line-height: 1.42857;">,</span> ADD<span class="s1" style="line-height: 1.42857;">,</span> SIZE<span class="s1" style="line-height: 1.42857;">,</span> REMOVE<span class="s1" style="line-height: 1.42857;">,</span> ITERATOR<span class="s1" style="line-height: 1.42857;">,</span> CLEAR<span class="s1" style="line-height: 1.42857;">,</span> RETAIN_ALL<span class="s1" style="line-height: 1.42857;">,</span> ARRAY<span class="s1" style="line-height: 1.42857;">,</span> DRAIN<span class="s1" style="line-height: 1.42857;">,</span> ELEMENT<span class="s1" style="line-height: 1.42857;">,</span> PEEK<span class="s1" style="line-height: 1.42857;">,</span> OFFER<span class="s1" style="line-height: 1.42857;">,</span> POLL<span class="s1" style="line-height: 1.42857;">,</span> TAKE<span class="s1" style="line-height: 1.42857;">,</span> PUT</code>.</p></td><td colspan="1" rowspan="1" class="confluenceT
d">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>configuration</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><pre class="p1">CollectionConfiguration</pre></td><td colspan="1" rowspan="1" class="confluenceTd">empty <code>CollectionConfiguration</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The configuration for this data structure. You can also specify inner properties by using the <code>config.</code> prefix.</p><p>For example: <code>?config.backups=4</code></p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>timeoutMillis</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Long</code></td><td colspan="1" rowspan="1" class="confluenceTd">---</td><td colspan="1" rowspan="1" class="confluenceTd">The <spa
n>timeout in milliseconds to use when invoking the OFFER or POLL operations.</span></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><span>Producer</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>capacity</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>int</code></td><td colspan="1" rowspan="1" class="confluenceTd">--- (unbounded)</td><td colspan="1" rowspan="1" class="confluenceTd">The queue capacity if you'd like to use a bounded queue.</td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><span>Producer</span></td></tr></tbody></table></div><h4 id="Ignite-Headersused.4">Headers used</h4><p>This endpoint uses the following headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><
th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteQueueOperation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.<span>IGNITE_QUEUE_OPERATION</span></code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteQueueOperation</code> enum</td><td colspan="1" rowspan="1" class="confluenceTd"><p>Allows you to dynamically change the queue operation.</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteQueueMaxElements</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_QUEUE_MAX_ELEMENTS</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Integer or int</code></td><td colspan="1" rowspan="1" class="confluenceTd">When invoking the DRAIN operation, the amount of items to drain.</td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteQueueTransferredCount</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code><span><span>IgniteConstants.</span></span>IGNITE_QUEUE_TRANSFERRED_COUNT</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code><span>Integer or int</span></code></td><td colspan="1" rowspan="1" class="confluenceTd">The amount of items transferred as the result of the DRAIN operation.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteQueueTimeoutMillis</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code><span><span>IgniteConstants.</span></span>IGNITE_QUEUE_TIMEOUT_MILLIS</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Long or long</code></td><td colspan="1" rowspan="1" class="confluenceTd">Dynamically sets the timeout in milliseconds to use when invoking the OFFER or POLL operations. </td></tr></tbody></table></div><h3 id="Ignite-IgniteIDGeneratorendpoin
t">Ignite ID Generator endpoint</h3><p>The Ignite ID Generator endpoint allows you to interact with <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/id-generator" rel="nofollow">Ignite Atomic Sequences and ID Generators</a>.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+</div></div><p>This endpoint only supports producers.</p><h3 id="Ignite-Options.5">Options</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>operation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteQueueOperation</code> enum</p></td><td colspan="1" rowspan="1" class="confluenceTd"><pre class="p1">---</pre></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The operation to invoke on the Ignite Queue.</p><p>Superseded by the <code>IgniteConstants.IGNITE_QUEUE_OPE
RATION</code> header in the IN message.</p><p>Possible values: <code>CONTAINS<span class="s1" style="line-height: 1.42857;">,</span> ADD<span class="s1" style="line-height: 1.42857;">,</span> SIZE<span class="s1" style="line-height: 1.42857;">,</span> REMOVE<span class="s1" style="line-height: 1.42857;">,</span> ITERATOR<span class="s1" style="line-height: 1.42857;">,</span> CLEAR<span class="s1" style="line-height: 1.42857;">,</span> RETAIN_ALL<span class="s1" style="line-height: 1.42857;">,</span> ARRAY<span class="s1" style="line-height: 1.42857;">,</span> DRAIN<span class="s1" style="line-height: 1.42857;">,</span> ELEMENT<span class="s1" style="line-height: 1.42857;">,</span> PEEK<span class="s1" style="line-height: 1.42857;">,</span> OFFER<span class="s1" style="line-height: 1.42857;">,</span> POLL<span class="s1" style="line-height: 1.42857;">,</span> TAKE<span class="s1" style="line-height: 1.42857;">,</span> PUT</code>.</p></td><td colspan="1" rowspan="1" class="confluenceT
d">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>configuration</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><pre class="p1">CollectionConfiguration</pre></td><td colspan="1" rowspan="1" class="confluenceTd">empty <code>CollectionConfiguration</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The configuration for this data structure. You can also specify inner properties by using the <code>config.</code> prefix.</p><p>For example: <code>?config.backups=4</code></p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>timeoutMillis</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Long</code><
/td><td colspan="1" rowspan="1" class="confluenceTd">---</td><td colspan="1" rowspan="1" class="confluenceTd">The <span>timeout in milliseconds to use when invoking the OFFER or POLL operations.</span></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>capacity</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>int</code></td><td colspan="1" rowspan="1" class="confluenceTd">--- (unbounded)</td><td colspan="1" rowspan="1" class="confluenceTd">The queue capacity if you'd like to use a bounded queue.</td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr></tbody></table></div><h3 id="Ignite-Headersused.4">Headers used</h3><p>This endpoint uses the follow
ing headers:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header name</th><th colspan="1" rowspan="1" class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Expected type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>CamelIgniteQueueOperation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.<span>IGNITE_QUEUE_OPERATION</span></code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteQueueOperation</code> enum</td><td colspan="1" rowspan="1" class="confluenceTd"><p>Allows you to dynamically change the queue operation.</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteQueueMaxElements</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>IgniteConstants.IGNITE_QUEUE_MAX_ELEMENTS</code></td><t
d colspan="1" rowspan="1" class="confluenceTd"><code>Integer or int</code></td><td colspan="1" rowspan="1" class="confluenceTd">When invoking the DRAIN operation, the amount of items to drain.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteQueueTransferredCount</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code><span><span>IgniteConstants.</span></span>IGNITE_QUEUE_TRANSFERRED_COUNT</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code><span>Integer or int</span></code></td><td colspan="1" rowspan="1" class="confluenceTd">The amount of items transferred as the result of the DRAIN operation.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>CamelIgniteQueueTimeoutMillis</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code><span><span>IgniteConstants.</span></span>IGNITE_QUEUE_TIMEOUT_MILLIS</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>Long or long</code></td><td colspan
="1" rowspan="1" class="confluenceTd">Dynamically sets the timeout in milliseconds to use when invoking the OFFER or POLL operations. </td></tr></tbody></table></div><h2 id="Ignite-IDGEN:IgniteIDGeneratorendpoint">IDGEN: Ignite ID Generator endpoint</h2><p>The Ignite ID Generator endpoint allows you to interact with <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/id-generator" rel="nofollow">Ignite Atomic Sequences and ID Generators</a>.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ignite:idgen:sequenceName?option1=value1&option2=value2...]]></script>
-</div></div><p>This endpoint only supports producers.</p><h4 id="Ignite-Options.6">Options</h4><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>operation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteIdGenOperation</code> enum</p></td><td colspan="1" rowspan="1" class="confluenceTd"><pre class="p1">---</pre></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The operation to invoke on the Ignite ID Generator.</p><p>Superseded by the <code>IgniteConstants.IGNITE_ID
GEN_OPERATION</code> header in the IN message.</p><p>Possible values: <code>ADD_AND_GET<span class="s1" style="line-height: 1.42857;">,</span> GET<span class="s1" style="line-height: 1.42857;">,</span> GET_AND_ADD<span class="s1" style="line-height: 1.42857;">,</span> GET_AND_INCREMENT<span class="s1" style="line-height: 1.42857;">,</span> INCREMENT_AND_GET</code>.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>configuration</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><pre class="p1">CollectionConfiguration</pre></td><td colspan="1" rowspan="1" class="confluenceTd">empty <code>CollectionConfiguration</code></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The configuration for this data structure. You can also specify inner properties by using the <code>config.</code> prefix.</p><p>For example: <code>?c
onfig.backups=4</code></p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd">Producer</td></tr></tbody></table></div><h2 id="Ignite-InitializingtheIgnitecomponent">Initializing the Ignite component</h2><p>Each instance of the Ignite component is associated with an underlying <code>org.apache.ignite.Ignite</code> instance. You can interact with two Ignite clusters by initializing two instances of the Ignite component and binding them to different <code>IgniteConfiguration</code>s. There are 3 ways to initialize the Ignite component:</p><ul><li>By passing in an existing <code><span>org.apache.ignite.Ignite</span></code> instance. Here's an example using Spring config:</li></ul><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+</div></div><p>This endpoint only supports producers.</p><h3 id="Ignite-Options.6">Options</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th><th colspan="1" rowspan="1" class="confluenceTh">Compulsory</th><th colspan="1" rowspan="1" class="confluenceTh">Consumer/producer</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>operation</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>IgniteIdGenOperation enum</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><pre class="p1"><code>---</code></pre></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The operation to invoke on the Ignite ID Generator.</p><p>Superseded by the <code>IgniteConsta
nts.IGNITE_IDGEN_OPERATION</code> header in the IN message.</p><p>Possible values: <code>ADD_AND_GET<span class="s1" style="line-height: 1.42857;">,</span> GET<span class="s1" style="line-height: 1.42857;">,</span> GET_AND_ADD<span class="s1" style="line-height: 1.42857;">,</span> GET_AND_INCREMENT<span class="s1" style="line-height: 1.42857;">,</span> INCREMENT_AND_GET</code>.</p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><code>configuration</code></p></td><td colspan="1" rowspan="1" class="confluenceTd"><pre class="p1">CollectionConfiguration</pre></td><td colspan="1" rowspan="1" class="confluenceTd">empty CollectionConfiguration</td><td colspan="1" rowspan="1" class="confluenceTd"><p>The configuration for this data structure. You can also specify inner properties by using t
he <code>config.</code> prefix.</p><p>For example: <code>?config.backups=4</code></p></td><td colspan="1" rowspan="1" class="confluenceTd">N</td><td colspan="1" rowspan="1" class="confluenceTd"><strong><span style="color: rgb(0,128,0);">Producer</span></strong></td></tr></tbody></table></div><h2 id="Ignite-InitializingtheIgnitecomponent">Initializing the Ignite component</h2><p>Each instance of the Ignite component is associated with an underlying <code>org.apache.ignite.Ignite</code> instance. You can interact with two Ignite clusters by initializing two instances of the Ignite component and binding them to different <code>IgniteConfiguration</code>s. There are 3 ways to initialize the Ignite component:</p><ul><li>By passing in an existing <code><span>org.apache.ignite.Ignite</span></code> instance. Here's an example using Spring config:</li></ul><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<script class="brush: xml; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[<bean name="ignite" class="org.apache.camel.component.ignite.IgniteComponent">
<property name="ignite" ref="ignite" />
</bean>]]></script>
@@ -123,7 +122,7 @@
<script class="brush: xml; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[<bean name="ignite" class="org.apache.camel.component.ignite.IgniteComponent">
<property name="configurationResource" value="file:[...]/ignite-config.xml" />
</bean>]]></script>
-</div></div><p><br clear="none">Additionally, if using Camel programmatically, there are several convenience static methods in <code>IgniteComponent</code> that return a component out of any of these configuration options:</p><ul><li><code>IgniteComponent#fromIgnite(Ignite)</code></li><li><code>IgniteComponent#fromConfiguration(IgniteConfiguration)</code></li><li><code>IgniteComponent#fromInputStream(InputStream)</code></li><li><code>IgniteComponent#fromUrl(URL)</code></li><li><p class="p1"><code>IgniteComponent#<span class="s2">fromLocation(</span>String)</code></p></li></ul><div><span style="font-family: monospace;"><br clear="none"></span></div><div>You may use those methods to quickly create an IgniteComponent with your chosen configuration technique.</div><h3 id="Ignite-Generaloptions">General options</h3><p>All endpoints share the following options:</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Option
</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Default value</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>propagateIncomingBodyIfNoReturnValue</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>boolean</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>true</code></td><td colspan="1" rowspan="1" class="confluenceTd">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.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>treatCollectionsAsCacheObjects</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>boolean</code></td><td colspan="1" rowspan="1" class="confluenceTd"><code>false</code></td><td colspan="1" rowspan="1" class="confluenceTd">Some Ignite operations can deal with multi
ple elements at once, if passed a Collection. Enabling this option will treat Collections as a single object, invoking the operation variant for cardinality 1.</td></tr></tbody></table></div><h2 id="Ignite-OSGiSupport">OSGi Support</h2><div class="confluence-information-macro confluence-information-macro-information"><span class="aui-icon aui-icon-small aui-iconfont-info confluence-information-macro-icon"></span><div class="confluence-information-macro-body"><p>Apache Ignite supports OSGi as of 1.5.0.final.</p></div></div><p>Installing the camel-ignite feature in a Karaf container will require the Ignite feature repository to be present.</p><p>Please refer to the OSGi section in the <a shape="rect" class="external-link" href="https://apacheignite.readme.io/docs/osgi-installation-in-karaf" rel="nofollow">Ignite documentation</a>.</p><p></p><h3 id="Ignite-SeeAlso">See Also</h3>
[... 5 lines stripped ...]
Modified: websites/production/camel/content/index.userimage/user-avatar
==============================================================================
Binary files - no diff available.